本月博客排行
-
第1名
龙儿筝 -
第2名
lerf -
第3名
fantaxy025025 - johnsmith9th
- zysnba
- xiangjie88
年度博客排行
-
第1名
青否云后端云 -
第2名
宏天软件 -
第3名
gashero - wy_19921005
- vipbooks
- benladeng5225
- e_e
- wallimn
- javashop
- ranbuijj
- fantaxy025025
- jickcai
- zw7534313
- qepwqnp
- 解宜然
- ssydxa219
- zysnba
- sichunli_030
- sam123456gz
- 龙儿筝
- arpenker
- tanling8334
- kaizi1992
- gaojingsong
- xpenxpen
- jh108020
- wiseboyloves
- ganxueyun
- xyuma
- xiangjie88
- wangchen.ily
- Jameslyy
- luxurioust
- lemonhandsome
- mengjichen
- jbosscn
- zxq_2017
- lzyfn123
- nychen2000
- forestqqqq
- wjianwei666
- ajinn
- zhanjia
- Xeden
- hanbaohong
- java-007
- 喧嚣求静
- kingwell.leng
- mwhgJava
- lich0079
最新文章列表
ActiveMQ死信队列
Apache的ActiveMQ是JMS的一个开源实现,下面来说说ActiveMQ的使用
1. admin的web管理
浏览器输入http://localhost:8161/,打开后台管理页面:
2. DLQ - 死信队列 (Dead Letter Queue)
用来保存处理失败或者过期的消息。
出现下面情况时,消息会被重发:
i. 事务会话被回滚。
ii. 事务会话在提交之前关闭。
ii ...
深入掌握JMS(十):JMSCorrelationID与Selector
本文转自:http://blog.csdn.net/iamfafa/article/details/6265357
前面讲过JMSCorrelationID主要是用来关联多个Message,例如需要回复一个消息的时候,通常把回复的消息的JMSCorrelationID设置为原来消息的ID。
在下面这个例子中,创建了三个消息生产者A,B,C和三个消息消费者A,B,C。生产者A给消费者A发 ...
深入掌握JMS(十一):TemporaryQueue和TemporaryTopic
本文转自:http://blog.csdn.net/iamfafa/article/details/6265369
TemporaryQueue和TemporaryTopic,从字面上就可以看出它们是“临时”的目的地。可以通过Session来创建,例如:
TemporaryQueue replyQueue = session.createTemporaryQueue();
虽然它们是由 ...
深入掌握JMS(九):Selector
本文转自:http://blog.csdn.net/iamfafa/article/details/6265290
前面的例子中创建一个消息消费者使用的是:
sesssion.createConsumer(destination)
另外,还提供了另一种方式:
sesssion.createConsumer(destination, selector)
这里selector是一个字符 ...
深入掌握JMS(八):JMSReplyTo
本文转自:http://blog.csdn.net/iamfafa/article/details/6265279
在下面的例子中,首先创建两个Queue,发送者给一个Queue发送,接收者接收到消息之后给另一个Queue回复一个Message,然后再创建一个消费者来接受所回复的消息。
import javax.jms.Connection;
import javax.jms.JMSExcep ...
深入掌握JMS(七):DeliveryMode例子
本文转自:http://blog.csdn.net/iamfafa/article/details/6265164
在下面的例子中,分别发送一个Persistent和nonpersistent的消息,然后关闭退出JMS。
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.MessagePr ...
深入掌握JMS(六):消息头
本文转自:http://blog.csdn.net/iamfafa/article/details/6264992
一个消息对象分为三部分:消息头(Headers),属性(Properties)和消息体(Payload)。
对于StreamMessage和MapMessage,消息本身就有特定的结构,而对于TextMessage,ObjectMessage和BytesMessage是无 ...
Sping整合ActiveMQ(三.Spring JMSTemplate 与 JMS 原生API比较)
Sping整合ActiveMQ(三.Spring JMSTemplate 与 JMS 原生API比较)
从以下几方面比较JMSUtil和Spring JmsTemplate
l 对JNDI的支持
l 对ConnectionFactory、Connection、Destination、Session、MessageProducer、MessageConsumer对象的处理
l ...
Sping整合ActiveMQ(二.Spring 对JMS的支持 )
Sping整合ActiveMQ(二.Spring 对JMS的支持 )
Spring提供了一个用于简化JMS API使用的抽象框架,用户利用Spring使用JMS可以不用关心connection factory,session等资源的管理.类似于对JDBC的抽象,Spring提供了一个JmsTemplate类,抽象了操作JMS都必须做的公共步骤,留下了callback方法给用户去实现,如提供消息 ...
Java消息服务(第二版)读书笔记
1. 消息传送机制基础
近年来,系统的复杂性和先进性增长非常显著,对于系统的可靠性、可伸缩性和灵活性等的要求要比以前要高。为了适应这种对更好更快的系统日益增长的需求,体系结构师、架构师和开发者已经开始利用消息传送机制,作为解决这些复杂问题的一种方式。
尽管近年来JMS API未发生显著的变化,但消息传送机制的使用方式有了很大的变化。解决可靠性和可伸缩性问题,已经广 ...
深入掌握JMS(五):实战Topic
本文转自:http://blog.csdn.net/iamfafa/article/details/6264698
与Queue不同的是,Topic实现的是发布/订阅模型,在下面的例子中,启动2个消费者共同监听一个Topic,然后循环给这个Topic中发送多个消息。
import javax.jms.Connection;
import javax.jms.JMSException;
...
深入掌握JMS(四):实战Queue
本文转自:http://blog.csdn.net/iamfafa/article/details/6264587
Queue实现的是点到点模型,在下面的例子中,启动2个消费者共同监听一个Queue,然后循环给这个Queue中发送多个消息,我们依然采用ActiveMQ。
import javax.jms.Connection;
import javax.jms.DeliveryMode;
...
深入掌握JMS(二):一个JMS例子
本文转自:http://blog.csdn.net/iamfafa/article/details/6264446
首先需要做的是选择一个JMS提供者,如果在JavaEE环境中可以不用考虑这些.
我们选择ActiveMQ,官方地址: http://activemq.apache.org/.网上有很多介绍ActiveMQ的文档,所以在这里就不介绍了.
按照上一讲的这个简图,
Con ...
深入掌握JMS(一):JSM基础
本文转自:http://blog.csdn.net/iamfafa/article/details/6264359
1.JMS基本概念
JMS(Java Message Service) 即Java消息服务。它提供标准的产生、发送、接收消息的接口简化企业应用的开发。它支持两种消息通信模型:点到点(point-to-point)(P2P)模型和发布/订阅(Pub/Sub)模型。
P2P模型规 ...
ActiveMQ 笔札 (一)
1.2 Using ActiveMQ: why and when
1.2.1 Loose coupling and ActiveMQ (松耦和)
Such a loosely coupled design is consid-ered to be asynchronous, where the calls from either application have no bea ...
activeMQ JMS监控配置
一、配置activeMQ
切换至 activemq解压目录/conf/
1、修改conf/中的activemq.xml,如下
<broker xmlns="http://activemq.org/config/1.0" brokerName="localhost" useJmx="true">
...