移除rabbitmq并添加rocketmq依赖

build.gradle

@@ -16,6 +16,7 @@ buildscript {
         mybatis_plus_boot_version = '1.0.5'
         activiti_starter_version = '6.0.0'
 //        rabbitmq_version = '5.1.2'
+        rocketmq_version = '4.2.0'
         xxljob_version = '1.9.0'
         swagger_version = '2.7.0'
         fastjson_version = '1.2.44'
@@ -77,17 +78,20 @@ subprojects {
         compile('org.springframework.boot:spring-boot-starter')
         compile('org.springframework.boot:spring-boot-starter-web')
         compile('org.springframework.boot:spring-boot-starter-aop')
-        compile('org.springframework.boot:spring-boot-starter-amqp')
+//        compile('org.springframework.boot:spring-boot-starter-amqp')
 //        compile('org.springframework.boot:spring-boot-starter-jta-atomikos')
         compile('org.springframework.boot:spring-boot-starter-cache')
         compile('org.springframework.boot:spring-boot-starter-data-redis')
 
         testCompile('org.springframework.boot:spring-boot-starter-test')
-        testCompile("junit:junit:$junit_version")
+//        testCompile("junit:junit:$junit_version")
 
         // session
 //        compile('org.springframework.session:spring-session-data-redis')
 
+        // mq
+        compile("org.apache.rocketmq:rocketmq-client:$rocketmq_version")
+
         // shiro
         compile("org.apache.shiro:shiro-spring:$shiro_version")
 

zen-mq/src/main/kotlin/com/gxzc/zen/mq/config/RabbitConfig.kt

@@ -1,35 +0,0 @@
-package com.gxzc.zen.mq.config
-
-import org.springframework.amqp.core.Binding
-import org.springframework.amqp.core.BindingBuilder
-import org.springframework.amqp.core.Queue
-import org.springframework.amqp.core.TopicExchange
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
-import org.springframework.context.annotation.Bean
-import org.springframework.context.annotation.Configuration
-
-/**
- *
- * @author NorthLan
- * @date 2018/1/31
- * @url https://noahlan.com
- */
-@Configuration
-@ConditionalOnProperty(prefix = "spring.rabbitmq", name = ["enable"], havingValue = "true")
-class RabbitConfig {
-
-    @Bean
-    fun queue(): Queue {
-        return Queue("q1")
-    }
-
-    @Bean
-    fun topicExchange(): TopicExchange {
-        return TopicExchange("te")
-    }
-
-    @Bean
-    fun binding(queue: Queue, topicExchange: TopicExchange): Binding {
-        return BindingBuilder.bind(queue).to(topicExchange).with("key.1")
-    }
-}

zen-mq/src/main/kotlin/com/gxzc/zen/mq/consumer/Receiver.kt

@@ -1,24 +0,0 @@
-//package com.gxzc.zen.mq.api
-//
-//import org.slf4j.LoggerFactory
-//import org.springframework.amqp.rabbit.annotation.RabbitListener
-//import org.springframework.stereotype.Component
-//
-///**
-// *
-// * @author NorthLan
-// * @date 2018/1/31
-// * @url https://noahlan.com
-// */
-//@Component
-//class Receiver {
-//    companion object {
-//        val logger = LoggerFactory.getLogger(Receiver::class.java)!!
-//    }
-//
-//    @RabbitListener(queues = ["q1"])
-//    fun processMessage(msg: String): String {
-//        logger.info("接收到来自q1的消息:{}", msg)
-//        return msg
-//    }
-//}

zen-mq/src/main/kotlin/com/gxzc/zen/mq/publisher/Sender.kt

@@ -1,51 +0,0 @@
-//package com.gxzc.zen.mq.publisher
-//
-//import org.slf4j.LoggerFactory
-//import org.springframework.amqp.core.Message
-//import org.springframework.amqp.rabbit.core.RabbitTemplate
-//import org.springframework.amqp.rabbit.support.CorrelationData
-//import org.springframework.beans.factory.annotation.Autowired
-//import org.springframework.stereotype.Component
-//import javax.annotation.PostConstruct
-//
-//
-///**
-// *
-// * @author NorthLan
-// * @date 2018/1/31
-// * @url https://noahlan.com
-// */
-//@Component
-//class Sender : RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback {
-//    companion object {
-//        val logger = LoggerFactory.getLogger(Sender::class.java)
-//    }
-//
-//    @Autowired
-//    private lateinit var rabbitTemplate: RabbitTemplate
-//
-//    @PostConstruct
-//    fun init() {
-//        rabbitTemplate.setConfirmCallback(this)
-//        rabbitTemplate.setReturnCallback(this)
-//    }
-//
-//    override fun returnedMessage(message: Message, replyCode: Int, replyText: String?, exchange: String?, routingKey: String?) {
-//        logger.info(message.messageProperties.correlationIdString + " 发送失败")
-//    }
-//
-//    override fun confirm(correlationData: CorrelationData?, ack: Boolean, cause: String?) {
-//        if (ack) {
-//            logger.info("消息发送成功:" + correlationData)
-//        } else {
-//            logger.info("消息发送失败:" + cause)
-//        }
-//    }
-//
-//    fun send(msg: String) {
-//        val correlationData = CorrelationData("2333")
-//        logger.info("发消息: {}", msg)
-//        val response = rabbitTemplate.convertSendAndReceive("te", "key.1", msg, correlationData).toString()
-//        logger.info("回执: {}", response)
-//    }
-//}