RabbitMQ 工作模式介绍 一、前言RabbitMQ 是一个由 erlang 开发的 AMQP (Advanced Message Queuing Protocol) 的开源实现。AMQP ：高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。 AMQP 的主要特征是面向消息、队列、路由（包括点对点和发布 / 订阅）、可靠性、安全。 RabbitMQ 是一个开源的 AMQP 实现，服务器端用 Erlang 语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP 等，支持 AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。应用场景：异步处理应用解耦流量削峰上篇《Centos7 安装RabbitMQ及配置（亲测）》，今天介绍一下RabbitMQ 工作模式二、工作模式介绍2.1简单模式与工作队列模式之所以这两个模式一起介绍，是因为它们的工作原理很简单，都是由生产者、队列、消费者组成。生产者是发送消息的用户的应用程序。队列是存储消息的缓冲器。消费者是接收消息的用户的应用程序。生产者负责生产消息，将消息发送到队列中，消费者监听队列，队列有消息就进行消费。当有多个消费者时，消费者平均消费队列中的消息。2.2 发布/订阅模式图中X代表交换机，它接收来自生产者的消息，另一方面将它们推送到队列 在消息产生之前，绑定队列的消费者都能收到消息。2.3 路由模式 需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。如果一个队列绑定到该交换机上要求路由键 （routingKey）“dog”，则只有被标记为 “dog” 的消息才被转发到该队列，不会转发 dog.puppy，也不会转发 dog.guard，只会转发dog。2.4 主题模式 发送到主题交换的消息不能具有任意的 routing_key - 它必须是由点分隔的单词列表。单词可以是任何内容，但通常它们指定与消息相关的一些功能。一些有效的路由键示例：“ stock.usd.nyse ”，“ nyse.vmw”，“ quick.orange.rabbit ”。路由密钥中可以包含任意数量的单词，最多可达255个字节。绑定密钥也必须采用相同的形式。主题交换背后的逻辑 类似于直接交换- 使用特定路由密钥发送的消息将被传递到与匹配的绑定密钥绑定的所有队列。但是绑定键有两个重要的特殊情况：（*）可以替代一个单词。（#）可以替换零个或多个单词。队列需要绑定要一个模式上。符号 “#” 匹配一个或多个词，符号“*”匹配不多不少一个词。因此“audit.#” 能够匹配到“audit.irs.corporate”，但是“audit.” 只会匹配到 “audit.irs”。相当于路由模式的模糊匹配 这里就只介绍五种模式，在 《RabbitMQ 官网》上提供了 6 中工作模式：简单模式、工作队列模式、发布/订阅模式、路由模式、主题模式 和 RPC 模式。 三、项目源码Spring Boot 整合 RabbitMQ（附源码）         

Caused by: java.lang.NoClassDefFoundError: org/mybatis/logging/LoggerFactory 原有依赖： <!-- mybatis-plus --> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.1.2</version> </dependency> <!--mysql--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.46</version> </dependency>异常问题：org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'sqlSessionFactory' defined in class path resource [com/baomidou/mybatisplus/autoconfigure/MybatisPlusAutoConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.ibatis.session.SqlSessionFactory]: Factory method 'sqlSessionFactory' threw exception; nested exception is java.lang.NoClassDefFoundError: org/mybatis/logging/LoggerFactory at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:627) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:607) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1288) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1127) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:538) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:498) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:846) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:863) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:142) ~[spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:316) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE] at com.comet.CometAdminApplication.main(CometAdminApplication.java:11) [classes/:na] Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.ibatis.session.SqlSessionFactory]: Factory method 'sqlSessionFactory' threw exception; nested exception is java.lang.NoClassDefFoundError: org/mybatis/logging/LoggerFactory at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:622) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] ... 19 common frames omitted Caused by: java.lang.NoClassDefFoundError: org/mybatis/logging/LoggerFactory at com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean.<clinit>(MybatisSqlSessionFactoryBean.java:97) ~[mybatis-plus-extension-3.1.2.jar:3.1.2] at com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration.sqlSessionFactory(MybatisPlusAutoConfiguration.java:142) ~[mybatis-plus-boot-starter-3.1.2.jar:3.1.2] at com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration$$EnhancerBySpringCGLIB$$84052ef9.CGLIB$sqlSessionFactory$1(<generated>) ~[mybatis-plus-boot-starter-3.1.2.jar:3.1.2] at com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration$$EnhancerBySpringCGLIB$$84052ef9$$FastClassBySpringCGLIB$$264ba30b.invoke(<generated>) ~[mybatis-plus-boot-starter-3.1.2.jar:3.1.2] at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244) ~[spring-core-5.1.3.RELEASE.jar:5.1.3.RELEASE] at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:363) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE] at com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration$$EnhancerBySpringCGLIB$$84052ef9.sqlSessionFactory(<generated>) ~[mybatis-plus-boot-starter-3.1.2.jar:3.1.2] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_131] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_131] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_131] at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_131] at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE] ... 20 common frames omitted Caused by: java.lang.ClassNotFoundException: org.mybatis.logging.LoggerFactory at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_131] at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_131] at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) ~[na:1.8.0_131] at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_131] ... 32 common frames omitted添加依赖： <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-extension</artifactId> <version>3.1.2</version> </dependency>    

mybatis传字符串分割 List<PayMember> moveList(Map<String,Object> map)；图中parentIds为====》1,2,3 字符串

io.swagger.models.parameters.AbstractSerializableParameter: Illegal DefaultValue for parameter type 在yml中添加logging: level: io.swagger.models.parameters.AbstractSerializableParameter: error 

Caused by: java.sql.SQLException: Value '0000-00-00 00:00:00' can not be represented as java.sql.Tim 异常问题：Caused by: java.sql.SQLException: Value '0000-00-00 00:00:00' can not be represented as java.sql.Timestamp原因：经过排查，发现数据表中有记录的time字段（属性为timestamp）其值为：“0000-00-00 00:00:00”或者是查询时该字段为null，在装换时间格式时出现此异常经过查询资料发现 “0000-00-00 00:00:00”在mysql中是作为一个特殊值存在的但 java.sql.Date 将其视为 不合法的值 格式不正确，所以才会报上面的错误；解决办法：在jdbc的url加上 zeroDateTimeBehavior参数：datasource.url=jdbc:mysql://localhost:3306/hunter?useUnicode=true&characterEncoding=utf8 &zeroDateTimeBehavior=convertToNullzeroDateTimeBehaviorzeroDateTimeBehavior=round是为了指定MySql中的DateTime字段默认值查询时的处理方式；默认是抛出异常，对于值为0000-00-00 00:00:00（默认值）的纪录，采用两种配置，会返回不同的结果：设置zeroDateTimeBehavior=round，返回值为 0001-01-01 00:00:00.0设置zeroDateTimeBehavior=convertToNull ，返回值为 null 

支付宝接口 支付宝接口支付宝

SEVERE: Could not contact [localhost:8005] (base port [8005] and offset [0]). Tomcat may not be runn 问题在关闭tomcat是提示（./shutdown.sh）：SEVERE: Could not contact localhost:8005. Tomcat may not be running. Jul 20, 2018 3:17:45 PM org.apache.catalina.startup.Catalina stopServer SEVERE: Catalina.stop: java.net.ConnectException: Connection refused (Connection refused) at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSoc at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.j at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at java.net.Socket.connect(Socket.java:538) at java.net.Socket.<init>(Socket.java:434) at java.net.Socket.<init>(Socket.java:211) at org.apache.catalina.startup.Catalina.stopServer(Catalina.java:498) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorIm at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAc at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.catalina.startup.Bootstrap.stopServer(Bootstrap.java:34 at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:430) 信息显示端口8005没有启动，同时命令查看进程端口netstat -tunlp|grep 8005 netstat -tunlp|grep 8080可以看到8080启动，8005没有启动。 解决方式修改${JAVA_HOME}/jre/lib/security/Java.securitysecurerandom.source=file:/dev/random 改为： securerandom.source=file:/dev/urandom然后杀死8080的进程kill -9 进程号重启tomcat就可以访问了   

> 1055 - Expression #2 of SELECT list is not in GROUP BY clause and contains 使用查询：select @@global.sql_mode结果：ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE, NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO, NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION centos下修改：/etc/my.cnf文件去掉ONLY_FULL_GROUP_BY，重新设置值在末尾添加[mysqld] sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION 重启MySQL服务service mysqld restart 

xml转换json工具类 导入依赖 <dependency> <groupId>dom4j</groupId> <artifactId>dom4j</artifactId> <version>1.6.1</version> </dependency>工具类 import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import org.dom4j.*; import java.io.File; import java.io.FileInputStream; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.util.List; import java.util.logging.Logger; /** * xml转换json工具类 * @Author: LiuYong * @Date:2019/12/11 10:00 * @Description: TODO xml转换json工具类 */ public class XmlToJsonUtils { private static Logger logger = Logger.getLogger(XmlToJsonUtils.class.getName()); public static void main(String[] args) throws Exception { String xml ="<xml>\n" + "<appid>wx2421b1c4370ec43b</appid>\n" + "<attach><![CDATA[att1]]></attach>\n" + "<body><![CDATA[JSAPI支付测试]]></body>\n" + "<device_info>1000</device_info>\n" + "<mch_id>10000100</mch_id>\n" + "<nonce_str>b927722419c52622651a871d1d9ed8b2</nonce_str>\n" + "<notify_url>http://wxpay.weixin.qq.com/pub_v2/pay/notify.php</notify_url>\n" + "<out_trade_no>1405713376</out_trade_no>\n" + "<spbill_create_ip>127.0.0.1</spbill_create_ip>\n" + "<total_fee>1</total_fee>\n" + "<trade_type>JSAPI</trade_type>\n" + "<sign><![CDATA[3CA89B5870F944736C657979192E1CF4]]></sign>\n" + "</xml>"; String s = xmlToJson(xml); System.out.println(s); JSONObject jsonObject = xml2Json(xml); System.out.println(jsonObject); } /** * xml字符串转json字符串 * @Author LiuYong * @Date 2019/12/11 10:06 * @Description TODO * @param xml * @return String **/ public static String xmlToJson(String xml) { Document doc; try { doc = DocumentHelper.parseText(xml); JSONObject json = new JSONObject(); dom4j2Json(doc.getRootElement(), json); return json.toJSONString(); } catch (DocumentException e) { logger.info("数据解析失败"); } return null; } /** * 根据xml文件路径转换json字符串 * @Author LiuYong * @Date 2019/12/11 10:06 * @Description TODO * @param path * @return String **/ public static String readFile(String path) throws Exception { File file = new File(path); FileInputStream fis = new FileInputStream(file); FileChannel fc = fis.getChannel(); ByteBuffer bb = ByteBuffer.allocate(new Long(file.length()).intValue()); /**fc向buffer中读入数据*/ fc.read(bb); bb.flip(); String str = new String(bb.array(), "UTF8"); fc.close(); fis.close(); return str; } /** * xml转json * * @param xmlStr * @return * @throws DocumentException */ public static JSONObject xml2Json(String xmlStr) throws DocumentException { Document doc = DocumentHelper.parseText(xmlStr); JSONObject json = new JSONObject(); dom4j2Json(doc.getRootElement(), json); return json; } /** * xml转json * @Author LiuYong * @Date 2019/12/11 10:07 * @Description TODO * @param element * @param json 外部接收json对象 **/ public static void dom4j2Json(Element element, JSONObject json) { /**如果是属性*/ for (Object o : element.attributes()) { Attribute attr = (Attribute) o; if (!isEmpty(attr.getValue())) { json.put("@" + attr.getName(), attr.getValue()); } } List<Element> chdEl = element.elements(); /**如果没有子元素,只有一个值*/ if (chdEl.isEmpty() && !isEmpty(element.getText())) { json.put(element.getName(), element.getText()); } /**有子元素*/ for (Element e : chdEl) { /**子元素存在子元素*/ if (!e.elements().isEmpty()) { JSONObject chdjson = new JSONObject(); dom4j2Json(e, chdjson); Object o = json.get(e.getName()); if (o != null) { JSONArray jsona = null; /**如果此元素已存在,则转为jsonArray*/ if (o instanceof JSONObject) { JSONObject jsono = (JSONObject) o; json.remove(e.getName()); jsona = new JSONArray(); jsona.add(jsono); jsona.add(chdjson); } if (o instanceof JSONArray) { jsona = (JSONArray) o; jsona.add(chdjson); } json.put(e.getName(), jsona); } else { if (!chdjson.isEmpty()) { json.put(e.getName(), chdjson); } } } else { /**子元素没有子元素*/ for (Object o : element.attributes()) { Attribute attr = (Attribute) o; if (!isEmpty(attr.getValue())) { json.put("@" + attr.getName(), attr.getValue()); } } if (!e.getText().isEmpty()) { json.put(e.getName(), e.getText()); } } } } /** * 是否为null * @Author LiuYong * @Date 2019/12/11 10:28 * @Description TODO * @param * @return **/ public static boolean isEmpty(String str) { if (str == null || str.trim().isEmpty() || str.equals("null")) { return true; } return false; } } 

根据网络地址下载图片及文件 /** * @Author LiuYong * @Date 2019/12/13 17:44 * @Description TODO * @param urlList url下载地址 * @param path 保存地址 * @return **/ private static void downloadPicture(String urlList,String path) { URL url = null; try { url = new URL(urlList); DataInputStream dataInputStream = new DataInputStream(url.openStream()); FileOutputStream fileOutputStream = new FileOutputStream(new File(path)); ByteArrayOutputStream output = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int length; while ((length = dataInputStream.read(buffer)) > 0) { output.write(buffer, 0, length); } fileOutputStream.write(output.toByteArray()); dataInputStream.close(); fileOutputStream.close(); } catch (MalformedURLException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }