来点实在的代码,用例子来说明:1.异步接收,主要设置messageListener。,然后编写onmessage方法,很简单a.客户端发送5条消息 1 package ch02.chat; 2 3 import javax.jms.JMSException; 4 5 public class C.....
分类:
其他好文 时间:
2014-11-05 21:11:28
阅读次数:
225
天空中飘着小雨,实在是适合写代码的时节。1 1 package ch02.chat; 2 3 import java.io.Serializable; 4 5 import javax.jms.Connection; 6 import javax.jms.ConnectionFact...
分类:
其他好文 时间:
2014-11-05 21:10:45
阅读次数:
1740
下面是ActiveMQ官网提供的文档。http://activemq.apache.org/spring-support.html下面是我添加的一些dependency: javax.jms javax.jms-api 2.0 org.apache.activemq a...
分类:
编程语言 时间:
2014-11-03 19:14:04
阅读次数:
328
首先需要下载ActiveMQ,下面的链接给我们列出了所有版本:http://activemq.apache.org/download-archives.html每个版本为不同的OS提供了链接:公司电脑是windows的,用目录下的activemq.bat启动:端口号默认是61616,可以在conf/...
分类:
其他好文 时间:
2014-11-03 19:08:38
阅读次数:
194
今天无聊写段代码。。学习一下activemq,简单封装了一下activemq 的topic api。跟jdbc很类似主要代码:import java.io.Serializable;import javax.jms.Connection;import javax.jms.ConnectionFact...
版本:activemq5.9.1zookeeper3.4.5leveldb1.5.0activemqzookeeper解压后配置conf内配置文件activemq:修改activemq.xml找到<persistenceAdapter>进行修改。<persistenceAdapter>
<!--<kahaDBdirectory="${activemq.data}/kahadb"/>-->
<replicated..
分类:
数据库 时间:
2014-10-28 18:10:55
阅读次数:
357
大家应该听我在前言篇里扯皮后,迫不及待要来一看Samza究竟是何物了吧?先了解一下Samza的Background是必不可少的(至少官网上是放在第一个的),我们需要从哪些技术背景去了解呢?
什么是消息(Messaging)?
消息系统是一种实现近实时异步计算的流行方案。消息产生时可以被放入一个消息队列(ActiveMQ,RabbitMQ)、发布-订阅系统(Kestrel...
分类:
其他好文 时间:
2014-10-27 23:10:44
阅读次数:
349
这里我们来详细讲解一下前一节的示例:Chat。先来了解Chat应用程序的TopicConnectionFactory和Topic的相关配置信息。在示例中,已经将它们分别命名为TopicCF和topic1。例如,使用ActiveMQ,可以在类路径中创建一个...
分类:
其他好文 时间:
2014-10-25 20:13:30
阅读次数:
252
1002mkdirActiveMQ1003chmod777ActiveMQ1004cdActiveMQ/1009wgethttp://mirror.bit.edu.cn/apache/activemq/5.10.0/apache-activemq-5.10.0-bin.tar.gz1011tarxzvfapache-activemq-5.10.0-bin.tar.gz1013cdapache-activemq-5.10.01014cdbin1015chmod755activemq1016nohup./acti..
分类:
系统相关 时间:
2014-10-16 23:18:04
阅读次数:
223
connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); 第一个参数当改...
分类:
其他好文 时间:
2014-10-16 19:45:42
阅读次数:
132