博客首页 → JMS

最新文章列表

深入掌握JMS（十）：JMSCorrelationID与Selector

        前面讲过JMSCorrelationID主要是用来关联多个Message，例如需要回复一个消息的时候，通常把回复的消息的JMSCorrelationID设置为原来消息的ID。         在下面这个例子中，创建了三个消息生产者A，B，C和三个消息消费者A，B，C。生产者A给消费者A发送一个消息，同时需要消费者A给它回复一个消息。B、C与A类似。          简图如下 ...
JMSActiveMQ 
bijian1013 评论(0) 有1474人浏览 2016-07-17 00:02

深入掌握JMS（九）：Selector

        前面的例子中创建一个消息消费者使用的是： sesssion.createConsumer(destination);         另外，还提供了另一种方式：  sesssion.createConsumer(destination, selector);         这里selector是一个字符串，用来过滤消息。也就是说，这种方式可以创建一个可以只接收特定消息的一 ...
JMSActiveMQ 
bijian1013 评论(0) 有998人浏览 2016-07-16 23:43

深入掌握JMS（八）：JMSReplyTo

        在下面的例子中，首先创建两个Queue，发送者给一个Queue发送，接收者接收到消息之后给另一个Queue回复一个Message，然后再创建一个消费者来接受所回复的消息。 package com.bijian.study; import javax.jms.Connection; import javax.jms.JMSException; import javax.j ...
JMSActiveMQ 
bijian1013 评论(0) 有938人浏览 2016-07-16 23:35

深入掌握JMS（七）：DeliveryMode例子

        在下面的例子中，分别发送一个Persistent和nonpersistent的消息，然后关闭退出JMS。 package com.bijian.study; import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.MessageProducer; import java ...
jmsActiveMQ 
bijian1013 评论(0) 有1111人浏览 2016-07-16 23:19

深入掌握JMS（六）：消息头

        一个消息对象分为三部分：消息头(Headers)，属性（Properties）和消息体（Payload）。对于StreamMessage和MapMessage，消息本身就有特定的结构，而对于TextMessage，ObjectMessage和BytesMessage是无结构的。一个消息可以包含一些重要的数据或者仅仅是一个事件的通知。          消息的Headers部分通常 ...
JMSActiveMQ 
bijian1013 评论(0) 有1226人浏览 2016-07-16 13:01

深入掌握JMS（五）：实战Topic

        与Queue不同的是，Topic实现的是发布/订阅模型，在下面的例子中，启动2个消费者共同监听一个Topic，然后循环给这个Topic中发送多个消息。 package com.bijian.study; import javax.jms.Connection; import javax.jms.JMSException; import javax.jms.Message ...
JMSActiveMQ 
bijian1013 评论(0) 有1144人浏览 2016-07-16 00:42

深入掌握JMS（四）：实战Queue

        Queue实现的是点到点模型，在下面的例子中，启动2个消费者共同监听一个Queue，然后循环给这个Queue中发送多个消息，我们依然采用ActiveMQ。  package com.bijian.study; import javax.jms.Connection; import javax.jms.JMSException; import javax.jms.Mes ...
JMSActiveMQ 
bijian1013 评论(0) 有958人浏览 2016-07-15 23:59

深入掌握JMS（三）：MessageListener

        消息的消费者接收消息可以采用两种方式：         1.consumer.receive() 或 consumer.receive(int timeout)；          2.注册一个MessageListener。          采用第一种方式，消息的接收者会一直等待下去，直到有消息到达，或者超时。后一种方式会注册一个监听器，当有消息到达的时候，会回调它的o ...
jmsActiveMQ 
bijian1013 评论(0) 有1299人浏览 2016-07-15 23:58

深入掌握JMS（二）：一个JMS例子

        前一讲简单的介绍了一下JMS的基本概念, 这一讲结合一个例子让大家深入理解前一讲的基本概念。         首先需要做的是选择一个JMS提供者, 如果在JavaEE环境中可以不用考虑这些。我们选择ActiveMQ，官方地址：http://activemq.apache.org/，网上有很多介绍ActiveMQ的文档, 所以在这里就不介绍了。         按照上一讲的这个 ...
jmsActiveMQ 
bijian1013 评论(0) 有1131人浏览 2016-07-15 23:55

深入掌握JMS（一）：JMS基础

一.JMS基本概念          JMS(Java Message Service) 即Java消息服务。它提供标准的产生、发送、接收消息的接口简化企业应用的开发。它支持两种消息通信模型：点到点（point-to-point）（P2P）模型和发布/订阅（Pub/Sub）模型。        P2P模型规定了一个消息只能有一个接收者;Pub/Sub 模型允许一个消息可以有多个接收者。对于点到点 ...
jmsActiveMQ 
bijian1013 评论(0) 有1084人浏览 2016-07-15 23:53

ActiveMQ与spring集成实例之使用消息监听器

        在EJB世界里，JMS消息最常用的功能之一是用于实现消息驱动Bean（MDB）。Spring提供了一个方法来创建消息驱动的POJO（MDP），并且不会把用户绑定在某个EJB容器上。         通常用消息监听器容器从JMS消息队列接收消息并驱动被注射进来的MDP。消息监听器容器负责消息接收的多线程处理并分发到各MDP中。一个消息侦听容器是MDP和消息提供者之间的一个中介，用 ...
springactivemqjms 
bijian1013 评论(0) 有3236人浏览 2016-07-15 00:58

Spring JMS 消息处理知识点

        JmsTemlate每次发送消息时都会重新创建连接，创建connection，session，创建productor。这是一个非常耗性能的地方，特别是大数据量的情况下。因此后来发送时采用mq的pooledConnectionFactory。这个类只会缓存connection，session和productor，不会缓存consumer。因此只适合于生产者发送消息。那为什么不缓存c ...
springjms 
bijian1013 评论(0) 有820人浏览 2016-07-09 23:51

深入理解DefaultMessageListenerContainer

一.DefaultMessageListenerContainer概述         DefaultMessageListenerContainer是一个用于异步消息监听的管理类。         DefaultMessageListenerContainer最简单的实现 ...
DefaultMessageListenerContainerJMS 
bijian1013 评论(0) 有13521人浏览 2016-07-06 23:47

基于WebSphere MQ发送消息的简单JMS实例

        基于WebSphere MQ发送消息的简单JMS实例。 MQSend.java package com.bijian.study; import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.Session; impo ...
WebSphere MQjms 
bijian1013 评论(0) 有1790人浏览 2016-07-02 16:53

ActiveMQ的安装与使用\ActiveMQ的使用代码样例（消费者）

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://mav ...
springjmsmail 
fjohnny 评论(0) 有770人浏览 2016-06-30 18:54

ActiveMQ的使用代码样例（异步邮件发送）生成者

public class MailParam { /** 发件人 **/ private String from; /** 收件人 **/ private String to; /** 主题 **/ private String subject; /** 邮件内容 **/ private String content; public MailParam ...
activemqspringjmslog4jjava 
fjohnny 评论(0) 有1074人浏览 2016-06-30 18:35

Spring JMS 消息处理-基于JNDI

        Spring JMS 把企业消息处理变得轻而易举，本文将使你快速了解使用Spring JMS框架和IBM WebSphere MQ7.5.0.2进行JMS消息处理的基础知识。         JMS PG 定义了 Java 应用程序通过面向消息的中间件（MOM）创建和交换消息的标准途径，下面将使用一个简单的示例来演示 Spring JMS 的特性。您将随我一道开发一个点对点的（ ...
JMSWebSphere MQ 
bijian1013 评论(0) 有3850人浏览 2016-06-08 21:05

ActiveMQ入门[转做笔记]

1.下载ActiveMQ 去官方网站下载：http://activemq.apache.org/ 2.运行ActiveMQ 解压缩apache-activemq-5.5.1-bin.zip，然后双击apache-activemq-5.5.1\bin\activemq.bat运行ActiveMQ程序。 启动ActiveMQ以后，登陆：http://localhost:8161/admin/，创建一个 ...
activemqjmsjava 
梦见x光 评论(0) 有420人浏览 2016-06-07 16:18

jms下载地址

http://archive.apache.org/dist/
jms 
lambertsprite 评论(0) 有495人浏览 2016-05-07 22:51

JTA分布式事务之JMS篇

 前言 我在上篇文章《【消息队列】ActiveMQ与Spring集成》讲解如何用spring编写一个简单的发送消息然后接收的JMS应用，不过例子中为了简单并没有使用事务，本文主要讲下如何增加事务的控制。在JMS中有两种事务控制方式：本地事务和JTA事务。由于实际的业务很少完全脱离数据库的使用，经常需要在一个事务中同时操作数据库和JMS，所以一般会使用JTA事务控制（分布式事务），本文就只讲JT ...
JTAJMS消息队列分布式 
hzy0769 评论(0) 有5027人浏览 2016-05-03 12:00

最近博客热门TAG

应用服务器(43288) Spring(40812) Hibernate(33330) Tomcat(28345) 框架(27200) 设计模式(24056) Servlet(23313) Struts(22805) Bean(22194) 企业应用(18268) thread(15826) 多线程(14801) SUN(11436) 虚拟机(11382) Cache(11314) Security(8002) SSH(7109) DAO(6880) MVC(6206) AOP(6187)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics