ActiveMQ 的安装与使用（单节点）
IP:192.168.4.101
环境：CentOS 6.6、JDK7
1、 安装 JDK 并配置环境变量（略）
JAVA_HOME=/usr/loc...
分类：
其他好文 时间：
2017-05-11 17:40:45
阅读次数：
431
1.PTP模型 PTP(Point-to-Point)模型是基于队列(Queue)的,对于PTP消息模型而言,它的消息目的是一个消息队列(Queue),消息生产者每次发送消息总是把消息送入消息队列中,消息消费者总是从消息队列中读取消息.先进队列的消息将先被消息消费者读取. 发送方发消息到队列，接收方 ...
分类：
Web程序 时间：
2017-05-10 17:05:32
阅读次数：
211
一、环境准备 1、上传 apache-activemq-5.11.1-bin.tar 和 zookeeper-3.4.5.tar.gz Linux服务器（/usr/local/install 目录下） zookeeper-3.4.5.tar.gz 上传方式相同。 二、Zookeeper方案 1、分别 ...
分类：
其他好文 时间：
2017-05-09 19:47:42
阅读次数：
257
一、简介ActiveMQ在接收消息的Client有以下几种操作的时候，需要重新传递消息：1：Client用了transactions，且在session中调用了rollback()2：Client用了transactions，且在调用commit()之前关闭3：Client在CLIENT_ACKNOWLEDGE的传递模式下，在session中调用了recover()二、定..
分类：
其他好文 时间：
2017-05-09 17:46:11
阅读次数：
1598
一、简介Queue中的消息是按照顺序被分发到consumers的。然而，当你有多个consumers同时从相同的queue中提取消息时，你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候，保证消息按照顺序处理是很重要的。如，你可能不希望在插入订单操作结束之前执行更新这个订..
分类：
其他好文 时间：
2017-05-09 13:49:20
阅读次数：
1604
一、简介延迟和定时消息投递（DelayandScheduleMessageDelivery）有时候我们不希望消息马上被broker投递出去，而是想要消息60秒以后发给消费者，或者我们想让消息没隔一定时间投递一次，一共投递指定的次数。。。类似这种需求，ActiveMQ提供了一种broker端消息定时调度机制。注..
分类：
其他好文 时间：
2017-05-09 13:42:04
阅读次数：
248
一、消息属性ActiveMQ支持很多消息属性，具体可以参见http://activemq.apache.org/activemq-message-properties.html常见的一些属性说明1：Queue的消息默认是持久化的2：消息的优先级默认是43：消息发送时设置了时间戳4：消息的过期时间默认是永不过期，过期的消息进入DLQ，可..
分类：
其他好文 时间：
2017-05-09 11:30:36
阅读次数：
286
一、分发策略（DispatchPolicies）1.1严格顺序分发策略（StrictOrderDispatchPolicy）通常ActiveMQ会保证topicconsumer以相同的顺序接收来自同一个producer的消息，但有时候也需要保证不同的topicconsumer以相同的顺序接收消息，然而，由于多线程和异步处理，不同的topicconsum..
分类：
其他好文 时间：
2017-05-08 18:40:48
阅读次数：
2614
一、消息游标1.1简介ActiveMQ发送持久消息的典型处理方式是：当消息的消费者准备就绪时，消息发送系统把存储的消息按批次发送给消费者，在发送完一个批次的消息后，指针的标记位置指向下一批次待发送消息的位置，进行后续的发送操作。这是一种比较健壮和灵活的消息发送方式，但..
分类：
其他好文 时间：
2017-05-08 14:26:22
阅读次数：
369
01）kfaka与传统意义上的mq的区别 更快！单机上万TPS 传统的MQ，消息被消化掉后会被mq删除，而kafka中消息被消化后不会被删除，而是到配置的expire时间后，才删除 传统的MQ，消息的Offset是由MQ维护，而kafka中消息的Offset是由客户端自己维护 分布式，把写入压力均摊 ...
分类：
其他好文 时间：
2017-05-07 20:30:32
阅读次数：
636
