From c46717d3eafa9a060f42dcfd7c42dab194e668e9 Mon Sep 17 00:00:00 2001 From: 3y Date: Mon, 11 Jul 2022 20:01:12 +0800 Subject: [PATCH] =?UTF-8?q?mq=20=E6=8F=92=E6=8B=94=E5=BC=8F=20=E8=AE=BE?= =?UTF-8?q?=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../receiver/eventbus/EventBusReceiver.java | 37 ++++++++++++ .../receiver/{ => kafka}/Receiver.java | 30 +++------- .../receiver/{ => kafka}/ReceiverStart.java | 6 +- .../receiver/service/ConsumeService.java | 32 +++++++++++ .../service/impl/ConsumeServiceImpl.java | 56 +++++++++++++++++++ .../service/api/impl/action/SendMqAction.java | 16 +++++- .../constans/MessageQueuePipeline.java | 14 +++++ .../austin/support/mq/SendMqService.java | 27 +++++++++ .../support/mq/eventbus/EventBusListener.java | 27 +++++++++ .../eventbus/EventBusSendMqServiceImpl.java | 52 +++++++++++++++++ .../mq/kafka/KafkaSendMqServiceImpl.java | 50 +++++++++++++++++ .../src/main/resources/application.properties | 18 ++++-- 12 files changed, 335 insertions(+), 30 deletions(-) create mode 100644 austin-handler/src/main/java/com/java3y/austin/handler/receiver/eventbus/EventBusReceiver.java rename austin-handler/src/main/java/com/java3y/austin/handler/receiver/{ => kafka}/Receiver.java (71%) rename austin-handler/src/main/java/com/java3y/austin/handler/receiver/{ => kafka}/ReceiverStart.java (86%) create mode 100644 austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/ConsumeService.java create mode 100644 austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java create mode 100644 austin-support/src/main/java/com/java3y/austin/support/constans/MessageQueuePipeline.java create mode 100644 austin-support/src/main/java/com/java3y/austin/support/mq/SendMqService.java create mode 100644 austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusListener.java create mode 100644 austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusSendMqServiceImpl.java create mode 100644 austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/eventbus/EventBusReceiver.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/eventbus/EventBusReceiver.java new file mode 100644 index 0000000..fdde8e7 --- /dev/null +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/eventbus/EventBusReceiver.java @@ -0,0 +1,37 @@ +package com.java3y.austin.handler.receiver.eventbus; + +import com.google.common.eventbus.Subscribe; +import com.java3y.austin.common.domain.TaskInfo; +import com.java3y.austin.handler.receiver.service.ConsumeService; +import com.java3y.austin.support.constans.MessageQueuePipeline; +import com.java3y.austin.support.domain.MessageTemplate; +import com.java3y.austin.support.mq.eventbus.EventBusListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @author 3y + */ +@Component +@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.EVENT_BUS) +public class EventBusReceiver implements EventBusListener { + + @Autowired + private ConsumeService consumeService; + + @Override + @Subscribe + public void consume(List lists) { + consumeService.consume2Send(lists); + + } + + @Override + @Subscribe + public void recall(MessageTemplate messageTemplate) { + consumeService.consume2recall(messageTemplate); + } +} diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/Receiver.java similarity index 71% rename from austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java rename to austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/Receiver.java index 29465ea..8f1ec37 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/Receiver.java @@ -1,4 +1,4 @@ -package com.java3y.austin.handler.receiver; +package com.java3y.austin.handler.receiver.kafka; import cn.hutool.core.collection.CollUtil; import com.alibaba.fastjson.JSON; @@ -9,13 +9,16 @@ import com.java3y.austin.common.enums.AnchorState; import com.java3y.austin.handler.handler.HandlerHolder; import com.java3y.austin.handler.pending.Task; import com.java3y.austin.handler.pending.TaskPendingHolder; +import com.java3y.austin.handler.receiver.service.ConsumeService; import com.java3y.austin.handler.utils.GroupIdMappingUtils; +import com.java3y.austin.support.constans.MessageQueuePipeline; import com.java3y.austin.support.domain.MessageTemplate; import com.java3y.austin.support.utils.LogUtils; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Scope; import org.springframework.kafka.annotation.KafkaListener; @@ -33,21 +36,10 @@ import java.util.Optional; @Slf4j @Component @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) +@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.KAFKA) public class Receiver { - private static final String LOG_BIZ_TYPE = "Receiver#consumer"; - private static final String LOG_BIZ_RECALL_TYPE = "Receiver#recall"; @Autowired - private ApplicationContext context; - - @Autowired - private TaskPendingHolder taskPendingHolder; - - @Autowired - private LogUtils logUtils; - - @Autowired - private HandlerHolder handlerHolder; - + private ConsumeService consumeService; /** * 发送消息 * @param consumerRecord @@ -60,16 +52,11 @@ public class Receiver { List taskInfoLists = JSON.parseArray(kafkaMessage.get(), TaskInfo.class); String messageGroupId = GroupIdMappingUtils.getGroupIdByTaskInfo(CollUtil.getFirst(taskInfoLists.iterator())); - /** * 每个消费者组 只消费 他们自身关心的消息 */ if (topicGroupId.equals(messageGroupId)) { - for (TaskInfo taskInfo : taskInfoLists) { - logUtils.print(LogParam.builder().bizType(LOG_BIZ_TYPE).object(taskInfo).build(), AnchorInfo.builder().ids(taskInfo.getReceiver()).businessId(taskInfo.getBusinessId()).state(AnchorState.RECEIVE.getCode()).build()); - Task task = context.getBean(Task.class).setTaskInfo(taskInfo); - taskPendingHolder.route(topicGroupId).execute(task); - } + consumeService.consume2Send(taskInfoLists); } } } @@ -83,8 +70,7 @@ public class Receiver { Optional kafkaMessage = Optional.ofNullable(consumerRecord.value()); if(kafkaMessage.isPresent()){ MessageTemplate messageTemplate = JSON.parseObject(kafkaMessage.get(), MessageTemplate.class); - logUtils.print(LogParam.builder().bizType(LOG_BIZ_RECALL_TYPE).object(messageTemplate).build()); - handlerHolder.route(messageTemplate.getSendChannel()).recall(messageTemplate); + consumeService.consume2recall(messageTemplate); } } } diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/ReceiverStart.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/ReceiverStart.java similarity index 86% rename from austin-handler/src/main/java/com/java3y/austin/handler/receiver/ReceiverStart.java rename to austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/ReceiverStart.java index a7f02a6..800a984 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/ReceiverStart.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/kafka/ReceiverStart.java @@ -1,7 +1,9 @@ -package com.java3y.austin.handler.receiver; +package com.java3y.austin.handler.receiver.kafka; import com.java3y.austin.handler.utils.GroupIdMappingUtils; +import com.java3y.austin.support.constans.MessageQueuePipeline; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; import org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor; @@ -18,7 +20,9 @@ import java.util.List; * @date 2021/12/4 */ @Service +@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.KAFKA) public class ReceiverStart { + @Autowired private ApplicationContext context; diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/ConsumeService.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/ConsumeService.java new file mode 100644 index 0000000..b3ed789 --- /dev/null +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/ConsumeService.java @@ -0,0 +1,32 @@ +package com.java3y.austin.handler.receiver.service; + + +import com.java3y.austin.common.domain.TaskInfo; +import com.java3y.austin.support.domain.MessageTemplate; + +import java.util.List; + +/** + * 消费消息服务 + * + * @author 3y + */ +public interface ConsumeService { + + /** + * 从MQ拉到消息进行消费，发送消息 + * + * @param taskInfoLists + */ + void consume2Send(List taskInfoLists); + + + /** + * 从MQ拉到消息进行消费，撤回消息 + * + * @param messageTemplate + */ + void consume2recall(MessageTemplate messageTemplate); + + +} diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java new file mode 100644 index 0000000..1983869 --- /dev/null +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java @@ -0,0 +1,56 @@ +package com.java3y.austin.handler.receiver.service.impl; + +import cn.hutool.core.collection.CollUtil; +import com.alibaba.fastjson.JSON; +import com.java3y.austin.common.domain.AnchorInfo; +import com.java3y.austin.common.domain.LogParam; +import com.java3y.austin.common.domain.TaskInfo; +import com.java3y.austin.common.enums.AnchorState; +import com.java3y.austin.handler.handler.HandlerHolder; +import com.java3y.austin.handler.pending.Task; +import com.java3y.austin.handler.pending.TaskPendingHolder; +import com.java3y.austin.handler.receiver.service.ConsumeService; +import com.java3y.austin.handler.utils.GroupIdMappingUtils; +import com.java3y.austin.support.domain.MessageTemplate; +import com.java3y.austin.support.utils.LogUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.ApplicationContext; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @author 3y + */ +@Service +public class ConsumeServiceImpl implements ConsumeService { + private static final String LOG_BIZ_TYPE = "Receiver#consumer"; + private static final String LOG_BIZ_RECALL_TYPE = "Receiver#recall"; + @Autowired + private ApplicationContext context; + + @Autowired + private TaskPendingHolder taskPendingHolder; + + @Autowired + private LogUtils logUtils; + + @Autowired + private HandlerHolder handlerHolder; + + @Override + public void consume2Send(List taskInfoLists) { + String topicGroupId = GroupIdMappingUtils.getGroupIdByTaskInfo(CollUtil.getFirst(taskInfoLists.iterator())); + for (TaskInfo taskInfo : taskInfoLists) { + logUtils.print(LogParam.builder().bizType(LOG_BIZ_TYPE).object(taskInfo).build(), AnchorInfo.builder().ids(taskInfo.getReceiver()).businessId(taskInfo.getBusinessId()).state(AnchorState.RECEIVE.getCode()).build()); + Task task = context.getBean(Task.class).setTaskInfo(taskInfo); + taskPendingHolder.route(topicGroupId).execute(task); + } + } + + @Override + public void consume2recall(MessageTemplate messageTemplate) { + logUtils.print(LogParam.builder().bizType(LOG_BIZ_RECALL_TYPE).object(messageTemplate).build()); + handlerHolder.route(messageTemplate.getSendChannel()).recall(messageTemplate); + } +} diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java index 7711a7e..fda58c7 100644 --- a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java +++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java @@ -4,10 +4,14 @@ import cn.hutool.core.collection.CollUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.serializer.SerializerFeature; import com.google.common.base.Throwables; +import com.google.common.eventbus.EventBus; +import com.java3y.austin.common.domain.TaskInfo; import com.java3y.austin.common.enums.RespStatusEnum; import com.java3y.austin.common.vo.BasicResultVO; import com.java3y.austin.service.api.enums.BusinessCode; import com.java3y.austin.service.api.impl.domain.SendTaskModel; +import com.java3y.austin.support.mq.SendMqService; +import com.java3y.austin.support.mq.eventbus.EventBusListener; import com.java3y.austin.support.pipeline.BusinessProcess; import com.java3y.austin.support.pipeline.ProcessContext; import com.java3y.austin.support.utils.KafkaUtils; @@ -16,6 +20,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; +import java.util.List; + /** * @author 3y * 将消息发送到MQ @@ -24,14 +30,17 @@ import org.springframework.stereotype.Service; @Service public class SendMqAction implements BusinessProcess { + @Autowired - private KafkaUtils kafkaUtils; + private SendMqService sendMqService; @Value("${austin.business.topic.name}") private String sendMessageTopic; @Value("${austin.business.recall.topic.name}") private String austinRecall; + @Value("${austin.business.tagId.value}") + private String tagId; @Override public void process(ProcessContext context) { @@ -39,10 +48,10 @@ public class SendMqAction implements BusinessProcess { try { if (BusinessCode.COMMON_SEND.getCode().equals(context.getCode())) { String message = JSON.toJSONString(sendTaskModel.getTaskInfo(), new SerializerFeature[]{SerializerFeature.WriteClassName}); - kafkaUtils.send(sendMessageTopic, message); + sendMqService.send(sendMessageTopic, message, tagId); } else if (BusinessCode.RECALL.getCode().equals(context.getCode())) { String message = JSON.toJSONString(sendTaskModel.getMessageTemplate(), new SerializerFeature[]{SerializerFeature.WriteClassName}); - kafkaUtils.send(austinRecall, message); + sendMqService.send(austinRecall, message, tagId); } } catch (Exception e) { context.setNeedBreak(true).setResponse(BasicResultVO.fail(RespStatusEnum.SERVICE_ERROR)); @@ -50,4 +59,5 @@ public class SendMqAction implements BusinessProcess { , JSON.toJSONString(CollUtil.getFirst(sendTaskModel.getTaskInfo().listIterator()))); } } + } diff --git a/austin-support/src/main/java/com/java3y/austin/support/constans/MessageQueuePipeline.java b/austin-support/src/main/java/com/java3y/austin/support/constans/MessageQueuePipeline.java new file mode 100644 index 0000000..3cf93fd --- /dev/null +++ b/austin-support/src/main/java/com/java3y/austin/support/constans/MessageQueuePipeline.java @@ -0,0 +1,14 @@ +package com.java3y.austin.support.constans; + + +/** + * 消息队列常量 + * + * @author 3y + */ +public interface MessageQueuePipeline { + String EVENT_BUS = "eventBus"; + String KAFKA = "kafka"; + String ROCKET_MQ = "rocketMq"; + +} diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/SendMqService.java b/austin-support/src/main/java/com/java3y/austin/support/mq/SendMqService.java new file mode 100644 index 0000000..8fc8e29 --- /dev/null +++ b/austin-support/src/main/java/com/java3y/austin/support/mq/SendMqService.java @@ -0,0 +1,27 @@ +package com.java3y.austin.support.mq; + + +/** + * @author 3y + * 发送数据至消息队列 + */ +public interface SendMqService { + /** + * 发送消息 + * + * @param topic + * @param jsonValue + * @param tagId + */ + void send(String topic, String jsonValue, String tagId); + + + /** + * 发送消息 + * + * @param topic + * @param jsonValue + */ + void send(String topic, String jsonValue); + +} diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusListener.java b/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusListener.java new file mode 100644 index 0000000..5f771fe --- /dev/null +++ b/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusListener.java @@ -0,0 +1,27 @@ +package com.java3y.austin.support.mq.eventbus; + + +import com.java3y.austin.common.domain.TaskInfo; +import com.java3y.austin.support.domain.MessageTemplate; + +import java.util.List; + +/** + * @author 3y + * 监听器 + */ +public interface EventBusListener { + + + /** + * 消费消息 + * @param lists + */ + void consume(List lists); + + /** + * 撤回消息 + * @param messageTemplate + */ + void recall(MessageTemplate messageTemplate); +} diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusSendMqServiceImpl.java b/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusSendMqServiceImpl.java new file mode 100644 index 0000000..38d5152 --- /dev/null +++ b/austin-support/src/main/java/com/java3y/austin/support/mq/eventbus/EventBusSendMqServiceImpl.java @@ -0,0 +1,52 @@ +package com.java3y.austin.support.mq.eventbus; + +import com.alibaba.fastjson.JSON; +import com.google.common.eventbus.EventBus; +import com.java3y.austin.common.domain.TaskInfo; +import com.java3y.austin.support.constans.MessageQueuePipeline; +import com.java3y.austin.support.domain.MessageTemplate; +import com.java3y.austin.support.mq.SendMqService; +import lombok.extern.slf4j.Slf4j; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; +import org.springframework.stereotype.Service; + + +/** + * @author 3y + * EventBus 发送实现类 + */ +@Slf4j +@Service +@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.EVENT_BUS) +public class EventBusSendMqServiceImpl implements SendMqService { + private EventBus eventBus = new EventBus(); + + @Autowired + private EventBusListener eventBusListener; + @Value("${austin.business.topic.name}") + private String sendTopic; + @Value("${austin.business.recall.topic.name}") + private String recallTopic; + /** + * 单机 队列默认不支持 tagId过滤（单机无必要） + * @param topic + * @param jsonValue + * @param tagId + */ + @Override + public void send(String topic, String jsonValue, String tagId) { + eventBus.register(eventBusListener); + if (topic.equals(sendTopic)) { + eventBus.post(JSON.parseArray(jsonValue, TaskInfo.class)); + } else if (topic.equals(recallTopic)) { + eventBus.post(JSON.parseObject(jsonValue, MessageTemplate.class)); + } + } + @Override + public void send(String topic, String jsonValue) { + send(topic, jsonValue, null); + } +} diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java b/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java new file mode 100644 index 0000000..8f0398b --- /dev/null +++ b/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java @@ -0,0 +1,50 @@ +package com.java3y.austin.support.mq.kafka; + +import cn.hutool.core.util.StrUtil; +import com.java3y.austin.support.constans.MessageQueuePipeline; +import com.java3y.austin.support.mq.SendMqService; +import lombok.extern.slf4j.Slf4j; +import org.apache.kafka.clients.producer.ProducerRecord; +import org.apache.kafka.common.header.Header; +import org.apache.kafka.common.header.internals.RecordHeader; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; +import org.springframework.kafka.core.KafkaTemplate; +import org.springframework.stereotype.Service; + +import java.nio.charset.StandardCharsets; +import java.util.Arrays; +import java.util.List; + + +/** + * @author 3y + * kafka 发送实现类 + */ +@Slf4j +@Service +@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.KAFKA) +public class KafkaSendMqServiceImpl implements SendMqService { + + @Autowired + private KafkaTemplate kafkaTemplate; + + @Value("${austin.business.tagId.key}") + private String tagIdKey; + + @Override + public void send(String topic, String jsonValue, String tagId) { + if (StrUtil.isNotBlank(tagId)) { + List
headers = Arrays.asList(new RecordHeader(tagIdKey, tagId.getBytes(StandardCharsets.UTF_8))); + kafkaTemplate.send(new ProducerRecord(topic, null, null, null, jsonValue, headers)); + } else { + kafkaTemplate.send(topic, jsonValue); + } + } + + @Override + public void send(String topic, String jsonValue) { + send(topic, jsonValue, null); + } +} diff --git a/austin-web/src/main/resources/application.properties b/austin-web/src/main/resources/application.properties index af2db2c..ced6182 100644 --- a/austin-web/src/main/resources/application.properties +++ b/austin-web/src/main/resources/application.properties @@ -2,21 +2,27 @@ # TODO please replace 【must】 config value # TODO please replace 【must】 config value + + # todo [database] ip/port/username/password 【must】 austin-database-ip= austin-database-port= austin-database-username= austin-database-password= -# todo [kafka] ip/port【must】 -austin-kafka-ip= -austin-kafka-port= - # todo [redis] ip/port/password【must】 austin-redis-ip= austin-redis-port= austin-redis-password= +# TODO kafka/eventbus +austin-mq-pipeline=eventbus + +# todo [kafka] ip/port【optional】, if austin-mq-pipeline=kafka 【must】 +austin-kafka-ip= +austin-kafka-port= + + # todo [xxl-job] switch/ip/port/【optional】 xxl-job.enabled=false austin-xxl-job-ip=127.0.0.1 @@ -49,6 +55,10 @@ spring.kafka.consumer.auto.offset.reset=earliest spring.kafka.consumer.auto-commit-interval=1000 spring.kafka.consumer.enable-auto-commit=true +# TODO austin support kafka tag filter,if you need, replace tagIdValue ,eg:com.java3y.austin.yyy +austin.business.tagId.key=kafka_tag_id +austin.business.tagId.value=com.java3y.austin.3y + ##################### redis properties ##################### spring.redis.host=${austin-redis-ip} spring.redis.port=${austin-redis-port}