qq7689791
- 浏览: 9736 次
- 性别:
- 来自: 北京
-
最新评论
-
The_Sword_Best：
最近也在读activemq的源码，你分析的很到位，拜读了。想问 ...
ActiveMQ源码架构解析第一节 -
dreamingcoder259：
写的很好，两篇我都看了，MQ的异常处理机制 是否能写一篇文章呢 ...
ActiveMQ源码架构解析第二节 -
houyujiangjun：
这个我还真不知道, 多谢
Timer在windows和linux下的不同表现
文章列表
讲解jdk源码中List接口之前我们先来看一个模式，迭代器设计模式。
迭代器设计模式主要是为了对容器提供统一的遍历接口，对于不同的数据结构的遍历方式由不同的iterator实现类所实现，而且也对原始数据进行了封 ...
ActiveMQ源码架构解析第二节
- 博客分类：
- ActiveMQ
欢迎继续收看我的文章。
本节主要内容就是讲解消息的传递方式，上一节已经讲解完客户端和broker端连接的建立方式，在Connection、Session、Producer类对象建立的同时，客户端和broker端会进行一些消息交互，ActiveMQ中把所有的消息交互的内容都叫做Command，每条消息对应一个Command，例如客户端刚连接到broker，broker会发送一个BrokerInfo信息到客户端，接着客户端会发送ConnectionInfo连接信息、
第一篇文章我们先从hello world写起，下面是使用java代码调用activemq的api发送一条消息。
public class test {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
工作之余就想写这篇文章了，但是种种原因没有写上，回到家中记录一下，以供在被岁月摧残的N多年之后回忆一下，也许还可以给别人带来帮助，而更多的是为了温故而知新，不善言谈，直接上代码。
class MyTask extends TimerTask {
public void run() {
System.out.print("hello everybody!");
}
}
Timer timer = new Timer();
timer.schedule(new MyTask(), 60*1000, 60*1000);
上面这段代码的意思非常简 ...