Dubbo高级篇1

╰+哭是因爲堅強的太久メ 2022-07-16 11:50 146阅读 0赞

消息中间件的定义  
Message-oriented middleware (MOM) is software infrastructure focused on sending and receiving messages between distributed systems.  
消息中间件是在分布式系统中完成消息的发送和接收的基础软件。

![Center][]

消息中间件的作用

消息中间件可利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，可以在分布式环境下扩展进程间的通信。

通过消息中间件，应用程序或组件之间可以进行可靠的异步通讯，从而降低系统之间的耦合度，提高系统的可扩展性和可用性。

应用程序A与应用程序B通信使用消息通信，可以异步通讯，即应用程序A不管应用B是否正常，只要消息中间件是正常的就OK了，如果应用程序B不正常，消息中间件会把应用程序A发给应用程序B的消息先缓存起来，等应用程序B正常，再交给应用程序B处理，此也可以解决分布式事务问题。

![Center 1][]

不使用消息中间件的分布式中得同时调用好多个服务，也依赖多个服务，耦合度高，同样，串联下的业务，可能存在等待时间，出现异常，数据的一致性很难保证

消息中间件在分布式系统中的作用介绍  
JMS （[Java ][Java]Message Service）  
JMS是JavaEE中的一个关于消息的规范，是一套与具体平台无关的API。  
JMS元素  
JMS提供者 ---- 连接面向消息中间件的，JMS接口的一个实现。  
JMS客户 ------ 生产或消费消息的基于[Java][Java 1]的应用程序或对象。  
JMS生产者 ---- 创建并发送消息的JMS客户。  
JMS消费者 ---- 接收消息的JMS客户。  
JMS消息 ------ 可以在JMS客户之间传递的数据的对象  
JMS队列 ------ 一个容纳那些被发送的等待阅读的消息的区域。  
JMS主题 ------ 一种支持发送消息给多个订阅者的机制。  
JMS应用程序接口  
ConnectionFactory（连接工厂）------ 用户用来创建到JMS提供者的连接的被管对象。  
Connection（连接）------------------- 连接代表了应用程序和消息服务器之间的通信链路。  
Destination（目标）------------------- 消息发布和接收的地点，或者是队列，或者是主题。  
MessageProducer（消息生产者）----- 由会话创建的对象，用于发送消息到目标。  
MessageConsumer（消息消费者）---- 由会话创建的对象，用于接收发送到目标的消息。  
Message（消息）---------------------- 是在消费者和生产者之间传送的对象。

JMS消息模型

1.点对点或队列模型

![Center 2][]

JMS点对点队列模型特点:

1、消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息

2、消息被消费以后，queue中再有的存储，所以消息消费者不可能消费到已被消费的消息。

3.Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费

JMS消息模型

发布者/订阅者模型

![Center 3][]

JMS 发布/订阅模型特点

消息生产者(发布)将消费发到topic中，同时有个多个消息消费者(订阅)消费该消息

发布到topic的消息会被所有订阅者消费

实现了JMS规范的消息中间件产品

ActiveMQ、RocketMQ、RabbitMQ、HornetQ.....

MQ对比与选择

1.activemq上传、解压安装

![Center 4][]

解压安装

![Center 5][]

2.移动activemq到指定目录

![Center 6][]

3.配置activemq端口

ActiveMQ 需要用到两个端口

一个是消息通讯的端口（默认为 61616）

一个是管理控制台端口（默认为 8161）可在conf/jetty.xml 中修改，如下

指定jetty端口

![Center 7][]

![Center 8][]

指定通讯端口

![Center 9][]

![Center 10][]

4.在防火墙中打开相应端口

![Center 11][]

5.启动activemq

![Center 12][]

在浏览器打开访问

![Center 13][]

以admin/admin登录

![Center 14][]

登录成功

![Center 15][]

6.安全配置（消息安全）

ActiveMQ 如果不加入安全机制的话，任何人只要知道消息服务的具体地址(包括 ip，端口，消息地址 \[队列或者主题地址 \]， )，都可以肆无忌惮的发送、接收消息。关于  ActiveMQ  安装配置 [http://activemq.apache.org/security.html][http_activemq.apache.org_security.html]

ActiveMQ 的消息安全配置策略有多种，我们以简单授权配置为例：在conf/activemq.xml 文件中在broker 标签最后加入以下内容即可：

![Center 16][]

定义了一个yixq 用户，密码为yxq123456，角色为users,admins

![Center 17][]

设置 admin 的用户名和密码:

确保 authenticate 的值为true（默认）

![Center 18][]

控制台的登录用户名密码保存在 conf/jetty-realm.properties 文件中,内容如下

![Center 19][]

注意:用户名和密码的格式是  
用户名 : 密码,角色名

重启，再登录就是新设置的密码登录

7.加入环境变量:

![Center 20][]

8.设置开机启动：

\# vi /etc/rc.local

加入:

su - yxq -c '/home/yxq/app/activemq/bin/activemq start'

MQ 消息生产者也与消息消费者的 Demo 样例讲解

消息提供方:

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **package** com.edu.demo.mqtest;  
2.    
3.  **import** org.apache.commons.logging.Log;  
4.  **import** org.apache.commons.logging.LogFactory;  
5.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
6.    
7.  **import** com.edu.demo.mqtest.MQProducer;  
8.  **import** com.edu.demo.mqtest.params.MailParam;  
9.    
10. **public** **class** MQProducerTest \{  
11.     **private** **static** **final** Log log = LogFactory.getLog(MQProducerTest.**class**);  
12.   
13.     **public** **static** **void** main(String\[\] args) \{  
14.         **try** \{  
15.             ClassPathXmlApplicationContext context = **new** ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");  
16.             context.start();  
17.   
18.             MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");  
19.             // 邮件发送  
20.             MailParam mail = **new** MailParam();  
21.             mail.setTo("18673132642@163.com");  
22.             mail.setSubject("ActiveMQ测试");  
23.             mail.setContent("通过ActiveMQ异步发送邮件！");  
24.   
25.             mqProducer.sendMessage(mail);  
26.   
27.             context.stop();  
28.         \} **catch** (Exception e) \{  
29.             log.error("==>MQ context start error:", e);  
30.             System.exit(0);  
31.         \} **finally** \{  
32.             log.info("===>System.exit");  
33.             System.exit(0);  
34.         \}  
35.     \}  
36. \}

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **package** com.edu.demo.mqtest;  
2.    
3.  **import** org.apache.commons.logging.Log;  
4.  **import** org.apache.commons.logging.LogFactory;  
5.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
6.    
7.  **import** com.edu.demo.mqtest.MQProducer;  
8.  **import** com.edu.demo.mqtest.params.MailParam;  
9.    
10. **public** **class** MQProducerTest \{  
11.     **private** **static** **final** Log log = LogFactory.getLog(MQProducerTest.**class**);  
12.   
13.     **public** **static** **void** main(String\[\] args) \{  
14.         **try** \{  
15.             ClassPathXmlApplicationContext context = **new** ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");  
16.             context.start();  
17.   
18.             MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");  
19.             // 邮件发送  
20.             MailParam mail = **new** MailParam();  
21.             mail.setTo("2779626653@163.com");  
22.             mail.setSubject("ActiveMQ测试");  
23.             mail.setContent("通过ActiveMQ异步发送邮件！");  
24.   
25.             mqProducer.sendMessage(mail);  
26.   
27.             context.stop();  
28.         \} **catch** (Exception e) \{  
29.             log.error("==>MQ context start error:", e);  
30.             System.exit(0);  
31.         \} **finally** \{  
32.             log.info("===>System.exit");  
33.             System.exit(0);  
34.         \}  
35.     \}  
36. \}

spring-context.xml

**\[html\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop"  
3.      xmlns:tx="http://www.springframework.org/schema/tx"  
4.      xsi:schemaLocation="http://www.springframework.org/schema/beans    
5.             http://www.springframework.org/schema/beans/spring-beans-3.2.xsd    
6.             http://www.springframework.org/schema/aop     
7.             http://www.springframework.org/schema/aop/spring-aop-3.2.xsd    
8.             http://www.springframework.org/schema/tx    
9.             http://www.springframework.org/schema/tx/spring-tx-3.2.xsd    
10.            http://www.springframework.org/schema/context    
11.            http://www.springframework.org/schema/context/spring-context-3.2.xsd"  
12.     default-autowire="byName" default-lazy-init="false"**>**   
13.       
14.       
15.     **<****context:annotation-config** **/>**  
16.   
17.       
18.     **<****context:component-scan** base-package="com.edu.demo" **/>**  
19.   
20.       
21.     **<****context:property-placeholder** location="classpath:mq.properties" **/>**  
22.   
23.       
24.     **<****aop:aspectj-autoproxy** proxy-target-class="true" **/>**     
25.       
26.     **<****import** resource="spring-mq.xml" **/>**  
27. **</****beans****>**

spring-mq.xml

**\[html\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans"  
3.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"  
4.      xmlns:context="http://www.springframework.org/schema/context"  
5.      xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"  
6.      xsi:schemaLocation="http://www.springframework.org/schema/beans    
7.             http://www.springframework.org/schema/beans/spring-beans-3.2.xsd    
8.             http://www.springframework.org/schema/aop     
9.             http://www.springframework.org/schema/aop/spring-aop-3.2.xsd    
10.            http://www.springframework.org/schema/tx    
11.            http://www.springframework.org/schema/tx/spring-tx-3.2.xsd    
12.            http://www.springframework.org/schema/context    
13.            http://www.springframework.org/schema/context/spring-context-3.2.xsd"  
14.     default-autowire="byName" default-lazy-init="false"**>**   
15.       
16.       
17.     **<****bean** id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"**>**  
18.           
19.         **<****property** name="brokerURL" value="tcp://192.168.1.121:61616" **/>**  
20.         **<****property** name="userName" value="yixq"**>****</****property****>**  
21.         **<****property** name="password" value="yxq123456"**>****</****property****>**   
22.     **</****bean****>**  
23.   
24.       
35.     **<****bean** id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"**>**  
36.           
37.         **<****property** name="targetConnectionFactory" ref="pooledConnectionFactory" **/>**  
38.     **</****bean****>**  
39.       
40.       
41.       
42.       
43.     **<****bean** id="activeMqJmsTemplate" class="org.springframework.jms.core.JmsTemplate"**>**    
44.             
45.         **<****property** name="connectionFactory" ref="connectionFactory"**/>**    
46.         **<****property** name="defaultDestinationName" value="com.edu.mqtest.v1"**>****</****property****>**  
47.     **</****bean****>**   
48.   
49. **</****beans****>**

pom.xml配置

测试类

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **package** com.edu.demo.mqtest;  
2.    
3.  **import** org.apache.commons.logging.Log;  
4.  **import** org.apache.commons.logging.LogFactory;  
5.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
6.    
7.  **import** com.edu.demo.mqtest.MQProducer;  
8.  **import** com.edu.demo.mqtest.params.MailParam;  
9.    
10. **public** **class** MQProducerTest \{  
11.     **private** **static** **final** Log log = LogFactory.getLog(MQProducerTest.**class**);  
12.   
13.     **public** **static** **void** main(String\[\] args) \{  
14.         **try** \{  
15.             ClassPathXmlApplicationContext context = **new** ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");  
16.             context.start();  
17.   
18.             MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");  
19.             // 邮件发送  
20.             MailParam mail = **new** MailParam();  
21.             mail.setTo("2779626653@163.com");  
22.             mail.setSubject("ActiveMQ测试");  
23.             mail.setContent("通过ActiveMQ异步发送邮件！");  
24.   
25.             mqProducer.sendMessage(mail);  
26.   
27.             context.stop();  
28.         \} **catch** (Exception e) \{  
29.             log.error("==>MQ context start error:", e);  
30.             System.exit(0);  
31.         \} **finally** \{  
32.             log.info("===>System.exit");  
33.             System.exit(0);  
34.         \}  
35.     \}  
36. \}

![Center 21][]

[Center]: /images/20220716/8c9b579548f44f728428f57ee8f46f8f.png
[Center 1]: /images/20220716/4fc6d196994f4cbf9a19143bc62c35e4.png
[Java]: http://lib.csdn.net/base/java
[Java 1]: http://lib.csdn.net/base/javaee
[Center 2]: /images/20220716/0b2bb7ea471e4758a7caf112f5abc27f.png
[Center 3]: /images/20220716/784484dfae4349bca1e0d585a2563908.png
[Center 4]: /images/20220716/1d1c570d1e28449f9ca9d4fa8fab9cad.png
[Center 5]: /images/20220716/196d4b00d6734de3b2fdb5b57f4dd668.png
[Center 6]: /images/20220716/4c8147a6ac2d43e3b65dd509cfb4b40d.png
[Center 7]: /images/20220716/e52fe9c425154397998395f71bf2f585.png
[Center 8]: /images/20220716/83e08d86f0fb4af99933258cc50bb1d5.png
[Center 9]: /images/20220716/54b5b52396b74901a9848c46246c4c0b.png
[Center 10]: /images/20220716/5150fdf4bc394e7d90d809cd35a501ca.png
[Center 11]: /images/20220716/5f1ba37c12a74e90a1f75c775332ca3c.png
[Center 12]: /images/20220716/9c38cc4a7b804bf1ad7a4bb07f0d10dd.png
[Center 13]: /images/20220716/64010e2a8b9b44d29a787c31d0e6023a.png
[Center 14]: /images/20220716/27ca7d400b0243c681ecbbc62fc36d99.png
[Center 15]: /images/20220716/ffab2ff9afc54eba9c2c67dee227c8bf.png
[http_activemq.apache.org_security.html]: http://activemq.apache.org/security.html
[Center 16]: /images/20220716/e8b7db048a78412db6e0ab86766edfe2.png
[Center 17]: /images/20220716/955c65c04b964ee79331b1f3ef6826ee.png
[Center 18]: /images/20220716/f1571cd3496444bda6d61aa9603588ac.png
[Center 19]: /images/20220716/d739778b77d54d73996f2f6f2376a846.png
[Center 20]: /images/20220716/1124c7ad372341f6bc62f2e90ff603cd.png
[view plain]: http://blog.csdn.net/hardworking0323/article/details/51001745#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/1650799
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/1650799/fork
[Center 21]: /images/20220716/21f1933c52eb4b248d4d0ef0175f3f35.png