- 浏览: 215008 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (244)
- java (23)
- java多线程 (7)
- 综合 (1)
- oracle10g (24)
- div+css (1)
- Flex (27)
- java Nio (1)
- java设计模式 (8)
- struts2 (10)
- spring3.0 (5)
- SSH (9)
- dwr (5)
- hibernate3.6 (17)
- dom4j (1)
- sql优化 (5)
- Quartz任务调度框架 (1)
- AOP (3)
- JavaScript (18)
- jquery (3)
- JSF (9)
- ruby (1)
- 正则表达式 (1)
- 明日准备 (2)
- eclipse (3)
- gvim (1)
- CMS (1)
- linux (6)
- 杂 (4)
- java 设计模式 (1)
- MySql (10)
- JBPM (4)
- JSP技术 (1)
- Mybatis And Ibatis (2)
- 经验之谈 (10)
- WebService (1)
- java分布式(高性能,高可用,可伸缩) (0)
- springMvc (2)
- redis (0)
- ant (1)
- Nutz (6)
- 配置管理 (0)
- css+div (1)
- eChars (1)
- angularJs (1)
- D3 (3)
- Scala (1)
最新评论
-
Cobain_LI:
Cobain_LI 写道学习了,之前一直都没注意到有这样的问题 ...
js面向对象3--更简单的原型模式已经带来的问题以及解决办法 -
Cobain_LI:
Cobain_LI 写道学习了,之前一直都没注意到有这样的问题 ...
js面向对象3--更简单的原型模式已经带来的问题以及解决办法 -
Cobain_LI:
有个小失误,144和147行多了两个花括号
js面向对象2--js中工厂模式的演化(重要,详细) -
Cobain_LI:
学习了,之前一直都没注意到有这样的问题
js面向对象3--更简单的原型模式已经带来的问题以及解决办法 -
YTT1121:
有网络拓扑发现的源代码么,或者您会编写么?可以有偿求购,搞科研 ...
flex 之twaver1--简单网络拓扑实现
1.前一讲简单的介绍了一下JMS的基本概念, 这一讲结合一个例子让大家深入理解前一讲的基本概念. 首先需要做的是选择一个JMS提供者, 如果在JavaEE环境中可以不用考虑这些. 我们选择ActiveMQ, 官方地址: http://activemq.apache.org/. 网上有很多介绍ActiveMQ的文档, 所以在这里就不介绍了.
2.按照上一讲的这个简图:
ConnectionFactory---->Connection--->Session--->Message
Destination + Session------------------------------------>Producer
Destination + Session------------------------------------>MessageConsumer
A)首先需要得到ConnectionFactoy和Destination,这里创建一个一对一的Queue作为Destination。
ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
Queue queue = new ActiveMQQueue("testQueue");
B)然后又ConnectionFactory创建一个Connection, 再启动这个Connection:
Connection connection = factory.createConnection();
connection.start();
C)接下来需要由Connection创建一个Session:
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
现在暂且不用管参数的含义, 以后会详细讲到.
D)下面就可以创建Message了,这里创建一个TextMessage。
Message message = session.createTextMessage("Hello JMS!");
E)要想把刚才创建的消息发送出去,需要由Session和Destination创建一个消息生产者:
MessageProducer producer = session.createProducer(queue);
F)下面就可以发送刚才创建的消息了:
producer.send(message);
G)消息发送完成之后,我们需要创建一个消息消费者来接收这个消息:
MessageConsumer comsumer = session.createConsumer(queue);
Message recvMessage = comsumer.receive();
H)消息消费者接收到这个消息之后,就可以得到它的内容:
System.out.println(((TextMessage)recvMessage).getText());
3.至此,一个简单的JMS例子就完成了。下面是全部源码 :
/**
* @author Administrator
* @desctiption 结合一个例子,深入理解JMS的基本概念
* 消息的消费者接收消息可以采用两种方式:
* 1、consumer.receive() 或 consumer.receive(int timeout);
* 2、注册一个MessageListener。
* 采用第一种方式,消息的接收者会一直等待下去,直到有消息到达,或者超时。
* 后一种方式会注册一个监听器,当有消息到达的时候,会回调它的onMessage()方法。
*/
package com.wl.jms;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
public class MessageSendAndReceive {
/**
* @param args
* @throws JMSException
*/
public static void main(String[] args) throws JMSException {
// TODO Auto-generated method stub
ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
Connection connection = factory.createConnection();
connection.start();
//创建消息的Destination
Queue queue = new ActiveMQQueue("testQueue");
final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//创建将要发送的消息
Message message = session.createTextMessage("Hello JMS!");
//创建消息生产者发送消息
MessageProducer producer = session.createProducer(queue);
producer.send(message);
System.out.println("Send Message Completed!");
//创建消息的接收者
MessageConsumer comsumer = session.createConsumer(queue);
//消息的消费者接收消息的第一种方式:consumer.receive() 或 consumer.receive(int timeout);
//Message recvMessage = comsumer.receive();
//System.out.println(((TextMessage)recvMessage).getText());
//消息的消费者接收消息的第二种方式:注册一个MessageListener
comsumer.setMessageListener(new MessageListener(){
public void onMessage(Message msg) {
// TODO Auto-generated method stub
TextMessage textMsg=(TextMessage)msg;
try {
System.out.println(textMsg.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
}
}
2.按照上一讲的这个简图:
ConnectionFactory---->Connection--->Session--->Message
Destination + Session------------------------------------>Producer
Destination + Session------------------------------------>MessageConsumer
A)首先需要得到ConnectionFactoy和Destination,这里创建一个一对一的Queue作为Destination。
ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
Queue queue = new ActiveMQQueue("testQueue");
B)然后又ConnectionFactory创建一个Connection, 再启动这个Connection:
Connection connection = factory.createConnection();
connection.start();
C)接下来需要由Connection创建一个Session:
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
现在暂且不用管参数的含义, 以后会详细讲到.
D)下面就可以创建Message了,这里创建一个TextMessage。
Message message = session.createTextMessage("Hello JMS!");
E)要想把刚才创建的消息发送出去,需要由Session和Destination创建一个消息生产者:
MessageProducer producer = session.createProducer(queue);
F)下面就可以发送刚才创建的消息了:
producer.send(message);
G)消息发送完成之后,我们需要创建一个消息消费者来接收这个消息:
MessageConsumer comsumer = session.createConsumer(queue);
Message recvMessage = comsumer.receive();
H)消息消费者接收到这个消息之后,就可以得到它的内容:
System.out.println(((TextMessage)recvMessage).getText());
3.至此,一个简单的JMS例子就完成了。下面是全部源码 :
/**
* @author Administrator
* @desctiption 结合一个例子,深入理解JMS的基本概念
* 消息的消费者接收消息可以采用两种方式:
* 1、consumer.receive() 或 consumer.receive(int timeout);
* 2、注册一个MessageListener。
* 采用第一种方式,消息的接收者会一直等待下去,直到有消息到达,或者超时。
* 后一种方式会注册一个监听器,当有消息到达的时候,会回调它的onMessage()方法。
*/
package com.wl.jms;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
public class MessageSendAndReceive {
/**
* @param args
* @throws JMSException
*/
public static void main(String[] args) throws JMSException {
// TODO Auto-generated method stub
ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
Connection connection = factory.createConnection();
connection.start();
//创建消息的Destination
Queue queue = new ActiveMQQueue("testQueue");
final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//创建将要发送的消息
Message message = session.createTextMessage("Hello JMS!");
//创建消息生产者发送消息
MessageProducer producer = session.createProducer(queue);
producer.send(message);
System.out.println("Send Message Completed!");
//创建消息的接收者
MessageConsumer comsumer = session.createConsumer(queue);
//消息的消费者接收消息的第一种方式:consumer.receive() 或 consumer.receive(int timeout);
//Message recvMessage = comsumer.receive();
//System.out.println(((TextMessage)recvMessage).getText());
//消息的消费者接收消息的第二种方式:注册一个MessageListener
comsumer.setMessageListener(new MessageListener(){
public void onMessage(Message msg) {
// TODO Auto-generated method stub
TextMessage textMsg=(TextMessage)msg;
try {
System.out.println(textMsg.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
}
}
发表评论
-
浅谈java接口中定义属性
2015-03-11 22:55 6947package com.supan.reflact; p ... -
java 泛型
2015-01-29 14:04 5611. 概述 在引入范型之前 ... -
配置jkstatus
2015-01-24 00:21 600在已配置完成的 apache 项目中 workers.pro ... -
apache+tomcat架设图片服务器
2015-01-23 22:15 1124apache + 2个tomcat分工指定: apac ... -
apache+tomcat实现负载均衡
2015-01-23 13:03 418所需材料: 1,apache_2.0.55-win32-x86 ... -
java web高并发解决方案
2015-01-23 01:28 854java处理高并发高负载类 ... -
java 实现简单及时通讯工具
2014-12-07 16:52 702客户端接受: package com.supan; i ... -
sql 语句优化
2014-12-03 23:50 450一: 尽量挑选自己需要的字段进行查询, 不要随便使用 s ... -
21312
2014-06-30 23:53 473http://supanccy2013.iteye.com/a ... -
java之jxl输入excel文件
2014-05-02 23:37 938注:原创作品,分享以供交流,转载请注明出处。 本博文需要引入 ... -
java虚拟机工作机制
2014-05-02 23:33 895注:原创作品,分享以供交流学习,转载请注明出处。 Java虚 ... -
java算法之 递归
2014-05-01 22:41 797注:原创作品,分享以供交流学习,转载请注明出处。 递 ... -
HttpRequest.getSession(boolean boo)方法注意点
2014-05-01 01:04 2079getSession(boolean create) ... -
java 之 String的那些事儿
2014-04-17 00:05 530equals方法和==的区别 首先大家知道,String既 ... -
java 之递归便利文件夹中的文件
2014-04-16 00:34 795import java.io.File; public ... -
java 之this,super关键字
2014-04-16 00:29 423this关键字的三种用法: 第一、通过this ... -
java 之md5加密
2014-04-16 00:25 586package com.supan.md5; import ... -
java String变量判空 效率
2014-04-09 23:16 1434Java中的String为引用类型,我们经常遇到判空的情况,s ... -
java socket简单写了一个即时通讯工具(代码有待优化。)
2014-02-17 08:42 24651,服务端不断轮训创建socket链接,一旦链接成功,启动两个 ... -
StringBuffer、String、StringBuilder的区别
2014-01-23 21:54 444String,StringBuffer与StringBuild ...
相关推荐
ActiveMq-JMS简单实例使用tomcat.doc
ActiveMq-JMS简单实例使用tomcat.pdf
ActiveMq-JMS-tomcat简单实例,内有代码文档和源码
含有八个独立运行的程序,分别设计JMS多个方面。 工程使用ActiveMQ,运行工程之前,请阅读doc.txt文档,并运行ActiveMQ
JMS入门(一)从简单示例开始 http://blog.csdn.net/lucien_zong/article/details/17204645
JMS如何整合Spring,简单实例,仅供参考
简单的实例:spring与jms结合实例
本例详细介绍了如何配置JMS服务以及weblogic的安装及在weblogic中配置JMS服务,例子简单易懂,文档含代码,适合初学者学习使用
spring-jms使用queue发送消息简单例子,详细参考:http://blog.csdn.net/xiejx618/article/details/38849249
学习jms+active+spring过程中自己写的一些简单例子,详情可见博文http://blog.csdn.net/dream_broken/article/details/43759911
jms 案例对于初学者很有用的偶,很简单很使用的例子
WebLogic下配置的JMS的教程,还有一个简单的实例,weblogic是8.1的
这个Demo程序演示了如何使用SpringBoot来构建一个最简单的基于ActiveMQ的JMS程序。
简单消息服务-httpsqs 博文链接:https://sosuny.iteye.com/blog/509846
简单的实现了jms的发送与接收,实现了异步通讯的功能 是一个与spring相结合的代码实例
NULL 博文链接:https://bijian1013.iteye.com/blog/2308734
Spring 集 成ActiveMQ 配置 异步RPC框架 Missian ActiveMq-JMS简单实例使用tomcat
基于Spring+JMS+ActiveMQ+Tomcat,做一个Spring4.1.0和ActiveMQ5.11.1整合实例,实现了Point-To-Point的异步队列消息和PUB/SUB(发布/订阅)模型,简单实例,不包含任何业务。
许多厂商目前都支持 JMS,包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ,这只是几个例子。 JMS 使您能够通过消息收发服务(有时称为消息中介程序或路由器)从一个 JMS 客户机向另一个 ...