MQ主要流程

解耦，异步，消峰

其中目的地主要为队列或者主题

队列点对点

消息的生产者

或者

这时消息的生产者名字已经出来

并且入队的数量变成了3

上述完成的也就是这部分

消息的消费者

前四步大同小异

这里需要和消息发送者的类型一致，所以需要强转一下

其中等待接收可以设置为一直等或者设置时长

最后再加上判断，良好的编程习惯

执行一下

出队变成了3，消费连接数变成了1，并且因为设置的receive为一直等，所以消费数量不会变化，除非关闭程序

不过这种方法是阻塞的

=====================

=====================

2通过监听的方式来消费消息(像是安卓中的监听事件)

前5步不变，从while处改变

加上System.in.read是让程序持续运行，不输入即一直运行，输入了然后就关闭，正好给消费时间

不然不写这部分，程序运行速度肯定超过消费速度

===============================

===============================

搞清楚了生产者消费者的基础程序和概念之后下面看一个重点

消费生产的冲突问题---三大消费问题

=================================

=================================

=================================

主题发布订阅-一对多

与队列基本一致，改一改名字和目的地即可

生产者

消费者同理也是如此操作即可

最后再说下MQ中间件的产品很多：kafka,RocketMQ,而学习了activeMQ基本原理相通，

JMS

而MQ基本属于JMS规范( JMS即Java消息服务(Java Message Service)应用程序接口，是一个Java平台中关于面向消息中间件(MOM)的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。)

而jms常见的问题就是保障消息可靠性保证，

1持久非持久2事务3签收

这就是涉及到消息头中的DeliveryMode

消息头

1JMSDestination 目的地

2JMSDeliveryMode 持久非持久模式

3JMSExpiration 过期时间

4   JMSPriority 优先级

5JMSMessageID 唯一识别编号

消息调用的幂等性就需要这个唯一识别编号

当然最后看了上面的一个一个设置消息头是不是很麻烦，上面只是为了演示方法，还可以通过send统一批处理

消息体

消息属性-更进一步增加识别度

怎样用：

JMS可靠性

1持久设置

这也是前面消息头讲过的

2事务设置(偏生产者)

生产者事务

前面我们都是用的false下面如设置为true看看

为什么false这么方便，自动提交还需要false呢

因为事务的特性：同生共死

所以再写代码时应该是这样用，假设一个生产者挂了，这一事务(加入有十个生产者)就因为都不能执行，这时应让事务回滚重新执行

即：正常给你提交，错误就再给你机会回滚直到生产成功

看看下面伪代码

3签收设置(偏消费者)

前面的情况是非事务，如果按照事务的情况，你设置手动的情况不ACK都不影响了

如一样可以接受

Broker

Broker可以被看成消息转发器。Broker也负责一些控制和管理操作。它能够定位服务端的位置，若发生异常，能够将异常捕获传给Client。Broker需要提供注册服务的接口给Server。如果请求来自其他的Broker，本地的Broker需要转发请求并最终将结果或异常回应给相应的远程Broker。Broker提供的服务和name service非常相像(如DNS、LDAP)。

l 责任：1. 注册服务。2. 提供服务API。3. 转发消息。4. 容错处理。5. 与其他Broker的交互。6。 定位服务。

导入依赖

然后写Broker

相当于ActiveMQ的一个mini版实例

就可以不再调用136而是本机