| 共 112 篇文章 |
|
ActiveMQ学习系列（四）JDBCPersistenceAdapter.cleanup(JDBCPersistenceAdapter.java:349)[activemq-jdbc-store-5.14.4.jar:5.14.4] at org.apache.activemq.store.jdbc.CREATE TABLE `ACTIVEMQ_LOCK` ( `ID` bigint(20) NOT NULL, `TIME` bigint(20) DEFAULT NULL, `BROKER_NAME` varchar(250) COLLATE latin1_bin DEFAULT NULL, PRIMARY KEY... 阅38 转2 评0 公众公开 18-05-03 11:26 |
ActiveMQ学习系列（二）java.naming.factory.initial = org.apache.activemq.jndi.private SimpleProducer() {} /** * @param args the destination name to send to and optionally, the number of * messages to send */ public static void main(String[] args) { Context jndiContext = null;if ((args.length <1) || (args.length >... 阅30 转0 评0 公众公开 18-05-03 11:26 |
ActiveMQ学习系列（一）JMS 使您能够通过消息收发服务（有时称为消息中介程序或路由器）从一个 JMS 客户机向另一个 JMS客户机发送消息。Apache ActiveMQ is released under the Apache 2.0 License.我这边下载的是linux版本，http://mirror.bit.edu.cn/apache//activemq/5.14.4/apache-activemq-5.14.4-bin.tar.gz.[root@mini1 local]# tar -zx... 阅31 转0 评0 公众公开 18-05-03 11:25 |
ActiveMQ如何接收离线消息。持久订阅时，客户端向ActiveMQ 注册一个识别自己身份的 ID，当这个客户端处于离线时，ActiveMQ会为这个 ID 保存所有发送到主题的消息，当客户端再次连接到ActiveMQ 时， 会根据自己的 ID 得到所有当自己处于离线时发送到主题的消息。activemq发布消息3，OK，消费者1，消费者2都收到，并进行处理。（6）activemq的设... 阅945 转1 评0 公众公开 18-05-02 17:45 |
基于ActiveMQ的Topic的数据同步——消费者持久化。首先，假设消费者都是普通的消费者，------------------------<1>activemq启动后，发布消息1，可惜，现在没有消费者启动着，也就是没有消费者进行了订阅。activemq发布消息2，OK，消费者1收到，并进行处理。activemq发布消息3，OK，消费者1，消费者2都收到，并进行处理。activemq发布消... 阅488 转1 评0 公众公开 18-03-21 10:40 |
/** * 提供消息操作的回调接口 * @author linwei * */ public interface MessageHandler { /** * 消息回调提供的调用方法 * @param message */ public void handle(Message message); } MultiThreadMessageListener.java. 阅67 转0 评0 公众公开 18-03-21 10:24 |
一个高稳定，可扩展的ActiveMQ的部署方案。ActiveMQ可以通过Networksof Brokers方式将多个Broker组成一个Cluster。在两个node上部署ActiveMQ的Broker，通过ActiveMQ的Networks of Brokers方式来组成Cluster。系统里的消息应用Instance通过ActiveMQ提供的client类库采用failover TCP的方式随机的接入到ActiveMQ的cluster中。如果某个ActiveMQ的n... 阅34 转0 评0 公众公开 18-03-21 10:13 |
Spring ActiveMQ 整合（二）: 重发机制（消息发送失败后的重新发送）--创建连接工厂 --> <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://localhost:61616"></property> <propert... 阅969 转1 评0 公众公开 18-03-21 09:26 |
Apache ActiveMQ 高级应用。1、将这个类放到activemq project/activemq-broker的相应路径下，在activemq-project/目录下执行mvn package；2、待maven执行完成后，将activemq-broker-version.jar和activemq-spring-version.jar放入到apache-activemq-version-bin/lib/目录下，替换对应的文件；至此我们就实现了Activemq的自定义分发策略功能，启... 阅111 转0 评0 公众公开 18-03-21 09:25 |
<code class="hljs asciidoc has-numbering"># hosts文件<span class="hljs-code">......192.168.61.139 activemq1192.168.61.138 activemq2......</span></code><ul style="" class="pre-numbering"><li>1</li><li>2</li><li>3</li&... 阅30 转0 评0 公众公开 18-03-20 16:11 |
