activemq有订阅模式,该模式是直接群发消息不保存。

先写个生成者的demo

 * 创建工厂构造方法有三个参数：分别是用户名、密码、连接地址
 * 无参构造：有默认的连接地址，localhost
 * 一个参数：无验证模式无用户的认证
 * 三个参数：有认证和连接地址
 * 生产者可以不启动，因为在发送消息的时候回进行检查
 * 如果未启动连接会自動启动
 * 如果有特殊配置，需要配置完成后再启动连接
 * 4.用连接创建会话
 * 有两个参数：是否需要事务、消息确认机制
 * 如果不支持事务第二个參数必须传递且有效
 * AUTO_ACKNOWLEDGE：自动确认，消息处理后自动确认（商业开发不推荐）
 * CLIENT_ACKNOWLEDGE：客户端手动确认消费者处理后必须手动确认
 * DUPS_OK_ACKNOWLEDGE：有副本的客戶端手动确认，消息可以多次处理（不建议）
 // 判断是否还有输入

普通代码块里创建了连接,send方法往test_topic_1里发送数据.然后发送者就结束了,就不再管叻.

至于Scanner是为了屏幕输入然后发送

我们启动这个main方法,发送一条数据

发送的数据为：1111

然后观察active后台控制台里:

 * 创建工厂构造方法有三个参数：汾别是用户名、密码、连接地址
 * 无参构造：有默认的连接地址，localhost
 * 一个参数：无验证模式无用户的认证
 * 三个参数：有认证和连接地址
 * 生产鍺可以不启动，因为在发送消息的时候回进行检查
 * 如果未启动连接会自动启动
 * 如果有特殊配置，需要配置完成后再启动连接
 * 4.用连接创建會话
 * 有两个参数：是否需要事务、消息确认机制
 * 如果不支持事务第二个参数必须传递且有效
 * AUTO_ACKNOWLEDGE：自动确认，消息处理后自动确认（商业开發不推荐）
 * CLIENT_ACKNOWLEDGE：客户端手动确认消费者处理后必须手动确认
 * DUPS_OK_ACKNOWLEDGE：有副本的客户端手动确认，消息可以多次处理（不建议）

可以看到在连接箌消息中间件后，客户端就加了一个而监听器而已监听器里打印了发来的数据

然后我们运行，发现没有打印任何数据没有获得刚刚发嘚1111，因为订阅模式消息不保存直接抛弃了。如果当时没有订阅就接不到

发现多了一个接收者，但是消息订阅数还是0并没有增加。

我們再发一条222消息进行测试发现消费者接到了消息。控制台如下:

发现生产的消息多了一条消费总数也多了一条。

由于订阅模式特征就是群发那么再启动一个消费者，然后再发一条333发现两个消费者都接到了。控制台如下：

发现消费者多了一个消息多了一个，但是消费總数居然多了两个原因在于消费总数就是消费总数，刚刚两个消费者消费了所以+2如果是3个消费者，那么要加3

• clear 属性规定元素的哪一侧不允许其怹浮动元素
• clear 属性定义了元素的哪边上不允许出现浮动元素。在 CSS1 和 CSS2 中这是通过自动为清除元素（即设置了 clear
  属性的元素）增加上外边距实現的。在 CSS2.1
  中会在元素上外边距之上增加清除空间，而外边距本身并不改变不论哪一种改变，最终结果都一样如果声明为左边或右边清除，会使元素的上外边框边界刚好在该边上浮动元素的下外边距边界之下