| @@ -1,7 +1,7 @@ | |||||
| package com.iformall.controller; | package com.iformall.controller; | ||||
| import com.iformall.common.ResultData; | import com.iformall.common.ResultData; | ||||
| import com.iformall.mq.MessageProducer; | |||||
| import com.iformall.mq.impl.RocketMqMessageProducer; | |||||
| import io.swagger.annotations.Api; | import io.swagger.annotations.Api; | ||||
| import io.swagger.annotations.ApiOperation; | import io.swagger.annotations.ApiOperation; | ||||
| import org.slf4j.Logger; | import org.slf4j.Logger; | ||||
| @@ -21,7 +21,7 @@ public class HomeController { | |||||
| private String version; | private String version; | ||||
| @Autowired | @Autowired | ||||
| private MessageProducer messageProducer; | |||||
| private RocketMqMessageProducer messageProducer; | |||||
| @ApiOperation("获取后端版本号") | @ApiOperation("获取后端版本号") | ||||
| @@ -0,0 +1,8 @@ | |||||
| package com.iformall.mq; | |||||
| public class MQConfig { | |||||
| public static class Impl { | |||||
| public static final String RABBIT_MQ = "rabbitmq"; | |||||
| public static final String ROCKET_MQ = "rocketmq"; | |||||
| } | |||||
| } | |||||
| @@ -0,0 +1,12 @@ | |||||
| package com.iformall.mq; | |||||
| import lombok.extern.slf4j.Slf4j; | |||||
| import org.springframework.stereotype.Service; | |||||
| @Slf4j | |||||
| @Service | |||||
| public class MqBaseConsumer { | |||||
| public void doMessage(String message) { | |||||
| log.info("received message: {}", message); | |||||
| } | |||||
| } | |||||
| @@ -1,20 +0,0 @@ | |||||
| package com.iformall.mq; | |||||
| import lombok.extern.slf4j.Slf4j; | |||||
| import org.rocketmq.starter.annotation.RocketMQListener; | |||||
| import org.rocketmq.starter.annotation.RocketMQMessage; | |||||
| import org.slf4j.Logger; | |||||
| import org.slf4j.LoggerFactory; | |||||
| import org.springframework.stereotype.Service; | |||||
| @Slf4j | |||||
| @Service | |||||
| @RocketMQListener(topic = "topic-1") | |||||
| public class MqConsumer { | |||||
| private final Logger log = LoggerFactory.getLogger(this.getClass()); | |||||
| @RocketMQMessage(messageClass = String.class, tag = "tag-1") | |||||
| public void onMessage(String message) { | |||||
| log.info("received message: {}", message); | |||||
| } | |||||
| } | |||||
| @@ -0,0 +1,21 @@ | |||||
| package com.iformall.mq.impl; | |||||
| import com.iformall.mq.MQConfig; | |||||
| import com.iformall.mq.MqBaseConsumer; | |||||
| import lombok.extern.slf4j.Slf4j; | |||||
| import org.rocketmq.starter.annotation.RocketMQListener; | |||||
| import org.rocketmq.starter.annotation.RocketMQMessage; | |||||
| import org.springframework.amqp.rabbit.annotation.RabbitListener; | |||||
| import org.springframework.context.annotation.Profile; | |||||
| import org.springframework.stereotype.Component; | |||||
| import org.springframework.stereotype.Service; | |||||
| @Component | |||||
| @Profile(MQConfig.Impl.RABBIT_MQ) | |||||
| public class RabbitMqConsumer extends MqBaseConsumer { | |||||
| @RabbitListener(queues = "topic-1") | |||||
| public void onMessage(String message) { | |||||
| doMessage(message); | |||||
| } | |||||
| } | |||||
| @@ -0,0 +1,30 @@ | |||||
| package com.iformall.mq.impl; | |||||
| import com.iformall.mq.MQConfig; | |||||
| import com.iformall.mq.MqBaseConsumer; | |||||
| import lombok.extern.slf4j.Slf4j; | |||||
| import org.rocketmq.starter.annotation.RocketMQListener; | |||||
| import org.rocketmq.starter.annotation.RocketMQMessage; | |||||
| <<<<<<< HEAD:mallinkService/src/main/java/com/iformall/mq/MqConsumer.java | |||||
| import org.slf4j.Logger; | |||||
| import org.slf4j.LoggerFactory; | |||||
| import org.springframework.stereotype.Service; | |||||
| ======= | |||||
| import org.springframework.context.annotation.Profile; | |||||
| >>>>>>> add rabbitmq:mallinkService/src/main/java/com/iformall/mq/impl/RocketMqConsumer.java | |||||
| @Slf4j | |||||
| @Profile(MQConfig.Impl.ROCKET_MQ) | |||||
| @RocketMQListener(topic = "topic-1") | |||||
| <<<<<<< HEAD:mallinkService/src/main/java/com/iformall/mq/MqConsumer.java | |||||
| public class MqConsumer { | |||||
| private final Logger log = LoggerFactory.getLogger(this.getClass()); | |||||
| ======= | |||||
| public class RocketMqConsumer extends MqBaseConsumer { | |||||
| >>>>>>> add rabbitmq:mallinkService/src/main/java/com/iformall/mq/impl/RocketMqConsumer.java | |||||
| @RocketMQMessage(messageClass = String.class, tag = "tag-1") | |||||
| public void onMessage(String message) { | |||||
| log.info("received message: {}", message); | |||||
| } | |||||
| } | |||||
| @@ -1,4 +1,4 @@ | |||||
| package com.iformall.mq; | |||||
| package com.iformall.mq.impl; | |||||
| import lombok.extern.slf4j.Slf4j; | import lombok.extern.slf4j.Slf4j; | ||||
| import org.apache.rocketmq.client.producer.DefaultMQProducer; | import org.apache.rocketmq.client.producer.DefaultMQProducer; | ||||
| @@ -20,9 +20,13 @@ import javax.annotation.PostConstruct; | |||||
| */ | */ | ||||
| @Service | @Service | ||||
| @Slf4j | @Slf4j | ||||
| <<<<<<< HEAD:mallinkService/src/main/java/com/iformall/mq/MessageProducer.java | |||||
| public class MessageProducer { | public class MessageProducer { | ||||
| private final Logger log = LoggerFactory.getLogger(this.getClass()); | private final Logger log = LoggerFactory.getLogger(this.getClass()); | ||||
| ======= | |||||
| public class RocketMqMessageProducer { | |||||
| >>>>>>> add rabbitmq:mallinkService/src/main/java/com/iformall/mq/impl/RocketMqMessageProducer.java | |||||
| @Value("${spring.rocketmq.nameServer}") | @Value("${spring.rocketmq.nameServer}") | ||||
| private String namesrvAddr; | private String namesrvAddr; | ||||