进阶-JMS 知识梳理

JMS

 

一、 概述与介绍

ActiveMQ 是Apache出品,最流行的、功能强大的即时通讯和集成模式的开源服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。提供客户端支持跨语言和协议,带有易于在充分支持JMS 1.1和1.4使用J2EE企业集成模式和许多先进的功能。

 

二、 特性

1、 多种语言和协议编写客户端。语言: Java、C、C++、C#、Ruby、Perl、Python、PHP。应用协议:OpenWire、Stomp REST、WS Notification、XMPP、AMQP

2、完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)

3、对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性

4、通过了常见J2EE服务器(如 Geronimo、JBoss 4、GlassFish、WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上

5、支持多种传送协议:in-VM、TCP、SSL、NIO、UDP、JGroups、JXTA

6、支持通过JDBC和journal提供高速的消息持久化

7、从设计上保证了高性能的集群,客户端-服务器,点对点

8、支持Ajax

9、支持与Axis的整合

10、可以很容易得调用内嵌JMS provider,进行测试

三、 安装

开发环境:

System:Windows

JDK:1.7+(如果MQ版本低于5.8是需要1.7以上的)

IDE:eclipse

apache ActiveMQ 5.8

1、 下载ActiveMQ,下载地址:http://www.apache.org/dyn/closer.cgi?path=/activemq/apache-activemq/5.8.0/apache-activemq-5.8.0-bin.zip

2、 解压apache-activemq-5.8.0.zip即可完成ActiveMQ的安装

3、 解压后目录结构如下

image

+bin (windows下面的bat和unix/linux下面的sh) 启动ActiveMQ的启动服务就在这里

+conf (activeMQ配置目录,包含最基本的activeMQ配置文件)

+data (默认是空的)

+docs (index,replease版本里面没有文档)

+example (几个例子)

+lib (activeMQ使用到的lib)

+webapps (系统管理员控制台代码)

+webapps-demo(系统示例代码)

-activemq-all-5.8.0.jar (ActiveMQ的binary)

-user-guide.html (部署指引)

-LICENSE.txt

-NOTICE.txt

-README.txt

其他文件就不相信介绍了,搞Java的应该都知道干什么用的。

你可以进入bin目录,使用activemq.bat双击启动(windows用户可以选择系统位数,如果你是linux的话,就用命令行的发送去启动),如果一切顺利,你就会看见类似下面的信息:

image

如果你看到这个,那么恭喜你成功了。如果你启动看到了异常信息:

Caused by: java.io.IOException: Failed to bind to server socket: tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600 due to: java.net.SocketException: Unrecognized Windows Sockets error: 0: JVM_Bind

 

报错1、那么我告诉你,很不幸,你的端口被占用了。接下来你大概想知道是哪个程序占用了你的端口,并kill掉该进程或服务。或者你要尝试修改ActiveMQ的默认端口61616(ActiveMQ使用的默认端口是61616),在大多数情况下,占用61616端口的是Internet Connection Sharing (ICS) 这个Windows服务,你只需停止它就可以启动ActiveMQ了。

报错2、集成后运行始终报错:ActiveMQConnectionFactory : Unsupported major.minor version 51.0
解决办法:http://blog.csdn.net/u012891504/article/details/52302131

    
报错3、启动分64位启动和31位启动 如果JDK是32位的但是启动是64位 则报错 需要版本统一

 

4、 启动成功就可以访问管理员界面:http://localhost:8161/admin,默认用户名和密码admin/admin。如果你想修改用户名和密码的话,在conf/jetty-realm.properties中修改即可。

常用的选项:Queues点对点

      Topics发布/订阅

image

其中在导航菜单中,Queues是队列方式消息。Topics是主题方式消息。Subscribers消息订阅监控查询。Connections可以查看链接数,分别可以查看xmpp、ssl、stomp、openwire、ws和网络链接。Network是网络链接数监控。Send可以发送消息数据。

5、 运行demo示例,在dos控制台输入activemq.bat xbean:../conf/activemq-demo.xml 即可启动demo示例。官方提供的user-guide.html中的access the web console中是提示输入:activemq.bat console xbean:conf/activemq-demo.xml,我用这种方式不成功。

当然你还可以用绝对的文件目录方式:activemq.bat xbean:file:D:/mq/conf/activemq-demo.xml

image

如果提示conf/activemq-demo.xml没有找到,你可以尝试改变下路径,也就是去掉上面的“..”。通过http://localhost:8161/demo/ 就可以访问示例了。

image

 

四、 消息示例

1、ActiviteMQ消息有3中形式

 

JMS 公共

点对点域

发布/订阅域

ConnectionFactory

QueueConnectionFactory

TopicConnectionFactory

Connection

QueueConnection

TopicConnection

Destination

Queue

Topic

Session

QueueSession

TopicSession

MessageProducer

QueueSender

TopicPublisher

MessageConsumer

QueueReceiver

TopicSubscriber

 

(1)、点对点方式(point-to-point)

点对点的消息发送方式主要建立在 Message Queue,Sender,reciever上,Message Queue 存贮消息,Sneder 发送消息,receive接收消息.具体点就是Sender Client发送Message Queue ,而 receiver Cliernt从Queue中接收消息和"发送消息已接受"到Quere,确认消息接收。消息发送客户端与接收客户端没有时间上的依赖,发送客户端可以在任何时刻发送信息到Queue,而不需要知道接收客户端是不是在运行

(2)、发布/订阅 方式(publish/subscriber Messaging)

发布/订阅方式用于多接收客户端的方式.作为发布订阅的方式,可能存在多个接收客户端,并且接收端客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的信息。作为subscriber ,在接收消息时有两种方法,destination的receive方法,和实现message listener 接口的onMessage 方法。

2、ActiviteMQ接收和发送消息基本流程

image

发送消息的基本步骤:

(1)、创建连接使用的工厂类JMS ConnectionFactory

(2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动

(3)、使用连接Connection 建立会话Session

(4)、使用会话Session和管理对象Destination创建消息生产者MessageSender

(5)、使用消息生产者MessageSender发送消息

消息接收者从JMS接受消息的步骤

(1)、创建连接使用的工厂类JMS ConnectionFactory

(2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动

(3)、使用连接Connection 建立会话Session

(4)、使用会话Session和管理对象Destination创建消息接收者MessageReceiver

(5)、使用消息接收者MessageReceiver接受消息,需要用setMessageListener将MessageListener接口绑定到MessageReceiver消息接收者必须实现了MessageListener接口,需要定义onMessage事件方法。

五、 代码示例

 创建session第二个参数详解

  Session.AUTO_ACKNOWLEDGE。 当客户成功的从receive方法返回的时候, 或者从MessageListener.onMessage
  方法成功返回的时候,会话自动确认客户收到的消息。


  Session.CLIENT_ACKNOWLEDGE。 客户通过消息的 acknowledge 方法确认消息。需要注意的是,在这种模
  式中,确认是在会话层上进行:确认一个被消费的消息将自动确认所有已被会话消 费的消息。例如,如果一
  个消息消费者消费了 10 个消息,然后确认第 5 个消息,那么所有 10 个消息都被确认。


  Session.DUPS_ACKNOWLEDGE。 该选择只是会话迟钝第确认消息的提交。如果 JMS provider 失败,那么可
  能会导致一些重复的消息。如果是重复的消息,那么 JMS provider 必须把消息头的 JMSRedelivered 字段设置
  为 true。 

 1 public class JMSProducer {
 2     
 3     private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;
 4     private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;
 5     private static final String URL = ActiveMQConnection.DEFAULT_BROKER_URL;
 6     
 7     public static void main(String[] args) {
 8         //连接工厂
 9         ConnectionFactory connectionFactory; 
10         //连接
11         Connection connection; 
12         //接受或者发送消息线程
13         Session session;
14         //消息目的地
15         Destination destination;
16         //消息生产者
17         MessageProducer messageProducer;
18         
19         //实例化连接工厂
20         connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);
21         
22         try {
23             //从工厂获取连接
24             connection = connectionFactory.createConnection();
25             //开启连接
26             connection.start();
27             //创建会话
28             session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
29             //点对点方式
30             //destination = session.createQueue("testQueue");
31             //订阅方式
32             destination = session.createTopic("topicTest");
33             //创建生产者
34             messageProducer = session.createProducer(destination);
35             //写个循环 发送10条消息
36             for(int i = 0;i<10;i++){
37                 //创建消息
38                 TextMessage text = session.createTextMessage("我是消息00"+i);
39                 //输出
40                 System.out.println("发布:我是消息00"+i);
41                 //使用生产者 提供方法 发送出去
42                 messageProducer.send(text);
43             }
44             //因为 是加事务的 所以一定要提交
45             session.commit();
46             //最后一定要将连接关闭 
47             connection.close(); 
48         } catch (Exception e) {
49             e.printStackTrace();
50         }
51         
52     }
53 }

消费者代码

 1 public class JMSConsumer {
 2     
 3     private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;
 4     private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;
 5     private static final String URL = ActiveMQConnection.DEFAULT_BROKER_URL;
 6     
 7     public static void main(String[] args) {
 8         //连接工厂
 9         ConnectionFactory connectionFactory; 
10         //连接
11         Connection connection; 
12         //会话
13         Session session;
14         //消费目的地
15         Destination destination;
16         //消费者
17         MessageConsumer consumer;
18         
19         
20         //实例化连接工厂
21         connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);
22         
23         //从工厂获取连接
24         try {
25             connection = connectionFactory.createConnection();
26             //开启连接
27             connection.start();
28             //获得会话 注意名字一定要一样和生产者
29             session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
30             
31             //获得消息队列
32             destination = session.createQueue("testQueue");
33             //订阅者
34             //destination = session.createTopic("topicTest");
35             
36             //创建消费者
37             consumer = session.createConsumer(destination);
38             //这种接受方式一般不常用
39             while(true){
40                 TextMessage message = (TextMessage) consumer.receive(100000);
41                 if(message!=null){
42                     System.out.println(message.getText());
43                 }else{
44                     break;
45                 }
46                 
47             }
48         } catch (JMSException e) {
49             // TODO Auto-generated catch block
50             e.printStackTrace();
51         }
52         
53     }
54 }

消费者监听代码

 1 public class JMSConsumer1 {
 2     
 3     private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;
 4     private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;
 5     private static final String URL = ActiveMQConnection.DEFAULT_BROKER_URL;
 6     
 7     public static void main(String[] args) {
 8         //连接工厂
 9         ConnectionFactory connectionFactory; 
10         //连接
11         Connection connection; 
12         //会话
13         Session session;
14         //消费目的地
15         Destination destination;
16         //消费者
17         MessageConsumer consumer;
18         
19         
20         //实例化连接工厂
21         connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);
22         
23         //从工厂获取连接
24         try {
25             connection = connectionFactory.createConnection();
26             //开启连接
27             connection.start();
28             //获得会话 注意名字一定要一样和生产者
29             session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
30             //获得消息队列
31             destination = session.createTopic("topicTest");
32             //创建消费者
33             consumer = session.createConsumer(destination);
34             //设置监听
35             consumer.setMessageListener(new Listener1());
36         } catch (JMSException e) {
37             // TODO Auto-generated catch block
38             e.printStackTrace();
39         }
40         
41     }
42 }

监听类

 1 public class Listener1 implements MessageListener {
 2 
 3     @Override
 4     public void onMessage(Message message) {
 5         try {
 6             System.out.println("订阅者"+((TextMessage)message).getText());
 7         } catch (JMSException e) {
 8             // TODO Auto-generated catch block
 9             e.printStackTrace();
10         }
11     }
12     
13 }

点对点方式和发布/订阅 代码区别 只有

            //点对点方式destination = session.createQueue("testQueue");//订阅方式destination = session.createTopic("topicTest");

 

转载于:https://www.cnblogs.com/yi1036943655/p/7151587.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/370021.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

android蓝牙pair,Android向更多蓝牙设备开放Fast Pair功能 配对更轻松了

原标题&#xff1a;Android向更多蓝牙设备开放Fast Pair功能 配对更轻松了 来源&#xff1a;cnBeta.COM蓝牙是一项应用非常广泛的无线技术&#xff0c;在无线音频配件、智能手表和智能家电中都广泛使用。不过蓝牙设备的配对体验并不优秀&#xff0c;而且无法实现跨平台的一致性…

python绘制帕累托图

python绘制帕累托图代码 1 import pandas as pd2 import matplotlib.pyplot as plt3 plt.rcParams[font.sans-serif][SimHei]#表示可以显示中文4 plt.rcParams[axes.unicode_minus]False#表示可以正常显示正负号5 datapd.read_csv(catering_dish_profit.csv,index_coltype)6 pr…

html5 测评游戏,暗黑之王评测:HTML5游戏铸就最华丽ARPG冒险

由白鹭时代(Egret Technology)与比悦科技联手推出的重度大型HTML5游戏《暗黑之王》&#xff0c;一款典型的ARPG手游&#xff0c;其HTML5版本推出以来&#xff0c;获得了来自业界、玩家和媒体的大量关注。其丰富的游戏内容和玩法&#xff0c;加上卓越的游戏性能表现&#xff0c;…

搞定flex布局

这几种方式的搭配使用可以轻松搞定 PC 端页面的常见需求&#xff0c;比如实现水平居中可以使用 margin: 0 auto&#xff0c;实现水平垂直同时居中可以如下设置&#xff1a;.dad {position: relative; } .son {position: absolute;margin: auto;top: 0;right: 0;bottom: 0;left…

Fiddler抓包使用教程-QuickExec

转载请标明出处&#xff1a;http://blog.csdn.net/zhaoyanjun6/article/details/73468287 本文出自【赵彦军的博客】 在 Fiddler 中自带了一个 QuickExec 命令行&#xff0c;用户可以直接输入并快速执行脚本命令。 常见命令 help 打开官方的使用页面介绍&#xff0c;所有的命令…

html5与css3都要学吗,前端要学css3吗?

前端要学css3&#xff1b;HTML5、CSS3是前端工程师必须要学会。现在移动端的兴起&#xff0c;导致web前端开发的技术逐变向css3和html5转变&#xff0c;所以css3一定要学。CSS3是CSS(层叠样式表)技术的升级版本&#xff0c;于1999年开始制订&#xff0c;2001年5月23日W3C完成了…

react 判断图片是否加载完成_React中型项目的优化实践

项目介绍整个项目大概有60个页面&#xff0c;用到的组件大概150&#xff0c;package里面的依赖大概有70个&#xff0c;应该勉强算得上是一个中型的React的项目了。下面给大家看看我们现在build一次项目的结果--打包时间约150s&#xff0c;打包完之后的资源gzip之后约1.2m&#…

搭建本地wordpress

1.首先&#xff0c;下载xampp&#xff0c;安装按默认勾选即可。 2.安装完成后&#xff0c;启动Apache和MySQL这两个服务。 启动后变成绿色&#xff0c;表示启动成功。 3.点击MySQL项的Admin进入数据库后台。 4.点击用户账户新建用户。 5.填写用户名&#xff0c;host name选本地…

Python基础【day02】:字符串(四)

在Python中字符串本身有带很多操作&#xff0c;字符串的特性&#xff0c;不可以被修改 0、字符串常用功能汇总 1、字符串的定义 #定义空字符串>>> name#定义非空字符串 >>> name"luoahong"#通过下标访问 >>> name[1] u#不能修改字符串的值…

html5 窗口变形,HTML5画布(变形)

坐标变换案例1&#xff1a;function draw(){var cdocument.getElementById("myCanvas");var cxt c.getContext("2d");cxt.translate(200,50);cxt.fillStylergba(255,0,0,0.25);for(var i0;i<40;i){cxt.translate(25,25);cxt.scale(0.9,0.9);cxt.rotate(…

appium GUI介绍

Appium作为APP端的自动化测试工具&#xff0c;具有很多的有点&#xff0c;今天主要介绍一下它的UI界面&#xff0c;包含其中的一些参数等。主要说的是windows下的APPIUM GUI。 先看一眼它的界面(版本为1.4.16.1) 注: 1.android Settings - Android设置按钮&#xff0c;所有和安…

迭代器模式和Java

大家好&#xff0c;在本文中&#xff0c;我们将检查Iterator Pattern 。 我知道你们中许多人已经使用过一种设计模式&#xff0c;但是也许您没有意识到它是模式&#xff0c;或者不知道它的巨大价值。 根据《 Head First Design 》一书&#xff1a; 迭代器模式提供了一种在不暴…

不使用JavaScript实现菜单的打开和关闭

我在写有菜单栏的网页时&#xff0c;基本都会用响应式设计来适配移动端&#xff0c;例如把不重要的菜单选项隐藏&#xff0c;或者创建一个菜单按钮来控制的菜单的打开和关闭之类的。而我之前一直是使用JavaScript来实现菜单的打开和关闭的&#xff0c;但最近在网上看到有人使用…

芝枝.计算机与人文科学,计算机与人文科学

计算机与人文科学(2013-03-13 13:24:17)标签&#xff1a;文化战争名著《静静的顿河》可以说从它诞生起便没有平静过&#xff0c;围绕它的作者所引起的争议&#xff0c;就像它获得诺贝尔文学奖一样&#xff0c;撼动文坛&#xff0c;有人指控肖洛霍夫是个骗子&#xff0c;《静静的…

HTML5 Canvas游戏开发实战 PDF扫描版

HTML5 Canvas游戏开发实战主要讲解使用HTML5 Canvas来开发和设计各类常见游戏的思路和技巧&#xff0c;在介绍HTML5 Canvas相关特性的同时&#xff0c;还通过游戏开发实例深入剖析了其内在原理&#xff0c;让读者不仅知其然&#xff0c;而且知其所以然。在本书中&#xff0c;除…

css3图片垂直居中

图片相对父元素垂直居中, css3属性给父级元素设置 display: -webkit-box; -moz-box-align: center; -webkit-box-align: center; -moz-box-pack: center; -webkit-box-pack: center; 需要注意的是&#xff1a; 父级元素要有确定的高度&#xff01;

网络局域网看不到其它计算机,局域网中看不到其它计算机怎么办

通过网上邻居或查看网络计算机时&#xff0c;看不到局域网中其它计算机&#xff0c;这是怎么回事呢?下面是学习啦小编给大家整理的一些有关看不到局域网中其它计算机的解决方法&#xff0c;希望对大家有帮助!局域网中看不到其它计算机的解决方法打开“控制面板”-“网络和Inte…

计算机二级高级应用考题,2016计算机二级MSOFFICE高级应用考试真题

2016计算机二级MSOFFICE高级应用考试真题离2016上半年的计算机等级考试只有一个多月了&#xff0c;为了帮助大家尽快考试过关&#xff0c;小编整理了计算机二级office考试题&#xff0c;希望能帮助到大家!(1)下列叙述中正确的是A)一个算法的空间复杂度大&#xff0c;则其时间复…

DBMS-数据库设计与E-R模型:E-R模型、约束、E-R图、E-R扩展特性、E-R图转换为关系模式、UML建模...

设计过程概览 1. 设计阶段 最初阶段&#xff1a;刻画未来数据库用户的数据需求&#xff0c;产品为用户需求规格说明&#xff1b; 概念设计阶段&#xff08;conceptual-design phase&#xff09;&#xff1a;&#xff08;关注描述抽象数据及其联系&#xff0c;通常使用实体-联系…

Java虚拟机:如何判定哪些对象可回收?

版权声明&#xff1a;本文为博主原创文章&#xff0c;转载请注明出处&#xff0c;欢迎交流学习&#xff01; 在堆内存中存放着Java程序中几乎所有的对象实例&#xff0c;堆内存的容量是有限的&#xff0c;Java虚拟机会对堆内存进行管理&#xff0c;回收已经“死去”的对象&…