mp配置启动

build.gradle

@@ -12,7 +12,7 @@ buildscript {
         spring_boot_version = '1.5.9.RELEASE'
         spring_data_version = '2.0.2.RELEASE'
         spring_data_elasticsearch_version = '3.0.2.RELEASE'
-        spring_rabbitmq_version = '2.0.1.RELEASE'
+//        spring_rabbitmq_version = '2.0.1.RELEASE'
 
         ehcache_version = '3.4.0'
         ehcache_core_version = '2.6.11'
@@ -21,7 +21,7 @@ buildscript {
         mybatis_plus_version = '2.1.8'
         mybatis_plus_boot_version = '1.0.5'
         activiti_version = '7-201712-EA'
-        rabbitmq_version = '5.1.2'
+//        rabbitmq_version = '5.1.2'
         xxljob_version = '1.9.0'
         swagger_version = '2.7.0'
 
@@ -95,7 +95,7 @@ subprojects {
 //        compile ("org.mybatis:mybatis-spring:$mybatiss_version")
         compile("com.baomidou:mybatis-plus:$mybatis_plus_version")
         compile("com.baomidou:mybatisplus-spring-boot-starter:$mybatis_plus_boot_version")
-        compile("com.rabbitmq:amqp-client:$rabbitmq_version")
+//        compile("com.rabbitmq:amqp-client:$rabbitmq_version")
         compile("com.xuxueli:xxl-job-core:$xxljob_version")
         compile("io.springfox:springfox-swagger2:$swagger_version")
         compile("io.springfox:springfox-swagger-ui:$swagger_version")

zen-common/src/main/java/TestMain.java

@@ -1,5 +0,0 @@
-public class TestMain {
-    public static void main(String[] args){
-        System.out.println("hello");
-    }
-}

zen-common/src/main/java/com/gxzc/zen/common/plug/Encodes.java

@@ -1,151 +0,0 @@
-/**
- * Copyright (c) 2005-2012 springside.org.cn
- */
-package com.gxzc.zen.common.plug;
-
-import org.apache.commons.codec.DecoderException;
-import org.apache.commons.codec.binary.Base64;
-import org.apache.commons.codec.binary.Hex;
-import org.apache.commons.lang3.StringEscapeUtils;
-
-import java.io.UnsupportedEncodingException;
-import java.net.URLDecoder;
-import java.net.URLEncoder;
-
-/**
- * 封装各种格式的编码解码工具类.
- * 1.Commons-Codec的 hex/base64 编码
- * 2.自制的base62 编码
- * 3.Commons-Lang的xml/html escape
- * 4.JDK提供的URLEncoder
- * @author calvin
- * @version 2013-01-15
- */
-public class Encodes {
-
-	private static final String DEFAULT_URL_ENCODING = "UTF-8";
-	private static final char[] BASE62 = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz".toCharArray();
-
-	/**
-	 * Hex编码.
-	 */
-	public static String encodeHex(byte[] input) {
-		return new String(Hex.encodeHex(input));
-	}
-
-	/**
-	 * Hex解码.
-	 */
-	public static byte[] decodeHex(String input) {
-		try {
-			return Hex.decodeHex(input.toCharArray());
-		} catch (DecoderException e) {
-			throw new RuntimeException(e);
-		}
-	}
-
-	/**
-	 * Base64编码.
-	 */
-	public static String encodeBase64(byte[] input) {
-		return new String(Base64.encodeBase64(input));
-	}
-	
-	/**
-	 * Base64编码.
-	 */
-	public static String encodeBase64(String input) {
-		try {
-			return new String(Base64.encodeBase64(input.getBytes(DEFAULT_URL_ENCODING)));
-		} catch (UnsupportedEncodingException e) {
-			return "";
-		}
-	}
-
-//	/**
-//	 * Base64编码, URL安全(将Base64中的URL非法字符'+'和'/'转为'-'和'_', 见RFC3548).
-//	 */
-//	public static String encodeUrlSafeBase64(byte[] input) {
-//		return Base64.encodeBase64URLSafe(input);
-//	}
-
-	/**
-	 * Base64解码.
-	 */
-	public static byte[] decodeBase64(String input) {
-		return Base64.decodeBase64(input.getBytes());
-	}
-	
-	/**
-	 * Base64解码.
-	 */
-	public static String decodeBase64String(String input) {
-		try {
-			return new String(Base64.decodeBase64(input.getBytes()), DEFAULT_URL_ENCODING);
-		} catch (UnsupportedEncodingException e) {
-			return "";
-		}
-	}
-
-	/**
-	 * Base62编码。
-	 */
-	public static String encodeBase62(byte[] input) {
-		char[] chars = new char[input.length];
-		for (int i = 0; i < input.length; i++) {
-			chars[i] = BASE62[((input[i] & 0xFF) % BASE62.length)];
-		}
-		return new String(chars);
-	}
-
-	/**
-	 * Html 转码.
-	 */
-	public static String escapeHtml(String html) {
-		return StringEscapeUtils.escapeHtml4(html);
-	}
-
-	/**
-	 * Html 解码.
-	 */
-	public static String unescapeHtml(String htmlEscaped) {
-		return StringEscapeUtils.unescapeHtml4(htmlEscaped);
-	}
-
-	/**
-	 * Xml 转码.
-	 */
-	public static String escapeXml(String xml) {
-		return StringEscapeUtils.escapeXml10(xml);
-	}
-
-	/**
-	 * Xml 解码.
-	 */
-	public static String unescapeXml(String xmlEscaped) {
-		return StringEscapeUtils.unescapeXml(xmlEscaped);
-	}
-
-	/**
-	 * URL 编码, Encode默认为UTF-8. 
-	 */
-	public static String urlEncode(String part) {
-		try {
-			return URLEncoder.encode(part, DEFAULT_URL_ENCODING);
-		} catch (UnsupportedEncodingException e) {
-			throw new RuntimeException(e);
-		}
-	}
-
-	/**
-	 * URL 解码, Encode默认为UTF-8. 
-	 */
-	public static String urlDecode(String part) {
-
-		try {
-			return URLDecoder.decode(part, DEFAULT_URL_ENCODING);
-		} catch (UnsupportedEncodingException e) {
-			throw new RuntimeException(e);
-		}
-	}
-}

zen-common/src/main/java/com/gxzc/zen/common/plug/IdGen.java

@@ -1,41 +0,0 @@
-/**
- * Copyright &copy; 2012-2016 <a href="https://github.com/thinkgem/jeesite">JeeSite</a> All rights reserved.
- */
-package com.gxzc.zen.common.plug;
-
-import java.security.SecureRandom;
-import java.util.UUID;
-
-/**
- * 封装各种生成唯一性ID算法的工具类.
- * @author ThinkGem
- * @version 2013-01-15
- */
-
-public class IdGen {
-
-	private static SecureRandom random = new SecureRandom();
-	
-	/**
-	 * 封装JDK自带的UUID, 通过Random数字生成, 中间无-分割.
-	 */
-	public static String uuid() {
-		return UUID.randomUUID().toString().replaceAll("-", "");
-	}
-	
-	/**
-	 * 使用SecureRandom随机生成Long. 
-	 */
-	public static long randomLong() {
-		return Math.abs(random.nextLong());
-	}
-
-	/**
-	 * 基于Base62编码的SecureRandom随机生成bytes.
-	 */
-	public static String randomBase62(int length) {
-		byte[] randomBytes = new byte[length];
-		random.nextBytes(randomBytes);
-		return Encodes.encodeBase62(randomBytes);
-	}
-}

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

@@ -0,0 +1,31 @@
+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.context.annotation.Bean
+
+/**
+ *
+ * @author NorthLan
+ * @date 2018/1/31
+ * @url https://noahlan.com
+ */
+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

@@ -0,0 +1,24 @@
+package com.gxzc.zen.mq.consumer
+
+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

@@ -0,0 +1,51 @@
+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)
+    }
+}

zen-mq/src/main/resources/application-mq.yml

@@ -1,9 +1,9 @@
 spring:
   rabbitmq:
-    host: localhost
+    host: 127.0.0.1
     port: 5672
-    username: root
-    password: root
+    username: admin
+    password: admin
     publisher-confirms: true
     publisher-returns: true
     template:

zen-orm/src/main/resources/application-orm.yml

@@ -35,9 +35,9 @@ spring:
 datasource:
   sys:
     name: archives_sys
-    url: jdbc:mysql://127.0.0.1:3306/archives_sys?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
-    username: root
-    password: root
+    url: jdbc:mysql://192.168.1.124:3307/archives_sys?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
+    username: archives
+    password: archives
     testWhileIdle: true
     testOnBorrow: false
     testOnReturn: false
@@ -54,9 +54,9 @@ datasource:
     minEvictableIdleTimeMillis: 30000
   bus:
     name: archives_receive
-    url: jdbc:mysql://127.0.0.1:3306/archives_rec?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
-    username: root
-    password: root
+    url: jdbc:mysql://192.168.1.124:3307/archives_receive?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
+    username: archives
+    password: archives
     testWhileIdle: true
     testOnBorrow: false
     testOnReturn: false

zen-web/build.gradle

@@ -3,4 +3,6 @@ apply plugin: 'war'
 dependencies {
     compile project(":zen-orm")
     compile project(":zen-api")
+    compile project(":zen-umps")
+    compile project(":zen-mq")
 }

zen-web/src/main/kotlin/com/gxzc/zen/controller/ExampleController.kt

@@ -1,10 +1,8 @@
 package com.gxzc.zen.controller
 
-import com.gxzc.zen.api.sys.mapper.SysDeptMapper
 import com.gxzc.zen.api.sys.model.SysDept
 import com.gxzc.zen.api.sys.service.ISysDeptService
-import com.gxzc.zen.orm.annotation.DynamicDataSource
-import com.gxzc.zen.orm.contants.DSKey
+import com.gxzc.zen.mq.publisher.Sender
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.transaction.annotation.Transactional
@@ -22,23 +20,25 @@ class ExampleController {
     lateinit var sysDeptService: ISysDeptService
 
     @Autowired
-    lateinit var sysDeptMapper: SysDeptMapper
+    lateinit var sender: Sender
 
     @GetMapping("test")
-    @DynamicDataSource(DSKey.DSKEY_SYS)
     @Transactional
     fun test() {
 //        logger.info("a: {}", sysDeptService.selectCount(EntityWrapper<SysDept>().where("1","1000L")))
 //        logger.info("b: {}", sysDeptMapper.selectCount(EntityWrapper<SysDept>()))
         sysDeptService.insert(SysDept().also {
             it.deptName = "ahaha"
-            it.sort = Integer(2)
+            it.sort = 2
             it.principal = "a"
         })
-        sysDeptService.insert(SysDept().also {
-            it.deptName = "我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjf我日你哥slkdfjslkdjflksdjfklsdjklfsjdlkfjsdlkfjsdlkfjlksdjflksdjfklsdjfklsdjklfsjdklfjsdklfjslkdjfklsdjfklsdjkflsjdklfjskldfjklsdjflksjf;lkasjdkl;fjasdlkf"
-            it.principal = "aaa"
-            it.sort = Integer(1)
-        })
+    }
+
+    @GetMapping("testMq")
+    fun testMq() {
+        for (i in 1..10) {
+            sender.send("msg $i")
+            Thread.sleep(1000)
+        }
     }
 }