专栏首页菩提树下的杨过JMS + jboss EAP 6.2 示例

JMS + jboss EAP 6.2 示例

.Net中如果需要消息队列功能,可以很方便的使用微软自带的MSMQ,对应到Java中,这个功能就是JMS(Java Message Service). 下面以Jboss EAP 6.2环境,介绍一下基本的用法:

JMS有二种基本的使用模式,

一种是点对点模式(即“一条”消息只能从“一个”发送方传输到“一个”接收方) - 这种模式下,发送方、接收方不必同时在线,消息在未取回走,一直存放在队列中。

另一种是发布/订阅模式,即一条消息(该模式下,称为“主题”),被一个发送方发送后,如果有多个接收方订阅了,这些接收方都能收到消息 - 这种模式下,发布者和订阅都必须同时在线,否则接收不到消息。

本文主要演示“点对点”模式的基本使用

一、jboss上创建相应的用户

JMS要求用户安全认证,即不允许随便谁都向队列里发送/接收,先在Jboss里创建一个用户。

%JBOSS_HOME%/bin/add-user.sh (mac/linux机环境,如果是windows,则是add-user.bat)

执行这个命令后,会出现文字交互界面,参考下图:

将创建一个msgUser的用户,提示:jboss eap 6.2安全性比较高,要求用户的密码满足复杂性要求(比如: Password1! ),如果太简单的密码,将创建失败

输完密码后,会提示该用户是否加入某个组,这里输入组名:guest (后面创建queue时会用到),参考下图:

注:上图中最后一个加密字符串,最好记录一下,某些应用要求安全认证时,需要在配置中配置该串(本文中暂时用不到)

创建完成后,实质上是在%JBOSS_HOME%/standalone/configuration的application-roles.properties、application-users.properties这二个文件中加了一些内容:

msgUser=5f7e011c53bb155cf99b9eeffccdad4d (这是application-users.properties中增加的内容)

msgUser=guest (这是application-roles.properties中增加的内容)

二、在jboss中创建队列

把%JBOSS_HOME%/standalone/configuration下的standalone.xml先改个名,然后把standalone-full.xml改成standalone.xml,启动jboss (即:要以standalone-full.xml中的内容做为配置启动jboss)

a)  图形界面方式

进入jboss的管理控制台,找到Profile -> Subsystems -> Messageing -> Destinations -> 查看 (参考下图)

默认情况,应该没有任何Queue

点击“添加”,Name这里输入myQueue(这个可以随便改),JNDI Names这里输入 java:jboss/exported/queue/mytest (最后面的mytest可以随便改,前面的部分建议不要改)

这样就创建一个Queue,到目前为止,还没看到跟安全认证相关的设置,切换到Seurity Settings面板

可以看到,默认情况下,创建的Queue允许"guest"角色 "发送"消息(Send这里是true)、"接收"消息(Consume这里是true),这就是为什么我们在第一步,要把msgUser这个用户加入guest组的原因

b) standalone.xml 配置方式

其实刚才的操作,最后的结果就是在standalone.xml中生成了如下代码:

<subsystemxmlns="urn:jboss:domain:messaging:1.4">

          ...

<security-settings>

<security-setting match="#">

<permission type="send" roles="guest"/>

<permission type="consume" roles="guest"/>

</security-setting>

</security-settings>

      ...

<jms-destinations>

<jms-queue name="myQueue">

//注:这一行建议也手动加上,对于单纯向Queue发送消息而言,加不加效果一样,

        //但是对于Message-drive-bean不加,偶尔会发现无法从queue/mytest接收到消息

<entry name="queue/mytest"/>  

<entryname="java:jboss/exported/queue/mytest"/>

<durable>true</durable>

</jms-queue>

</jms-destinations>

</hornetq-server>

</subsystem>

熟悉这个结构后,可以直接在standalone.xml中修改

c) 单独在deployments目录下部署 xxx-jms.xml (注:必须是以-jms.xml结尾的文件) 

内容如下:

<?xmlversion="1.0"encoding="UTF-8"?>

<messaging-deploymentxmlns="urn:jboss:messaging-deployment:1.0"><hornetq-server><jms-destinations><jms-queuename="fred"><entryname="jms/queue/fred"/><entryname="java:jboss/exported/jms/queue/fred"/></jms-queue></jms-destinations></hornetq-server></messaging-deployment>

注:经实际测试,建议所有内容都写在一行上,不加要其它任何空格或Tab字符,否则部署会失败(jboss EAP 6.1+版本对xml的校验极严格,哪怕是不可见字符,只要有一个字符校验失败,整个部署将失败)

另外:该方式部署的queue,在管理控制界面上看不到,但是代码可访问

三、编写测试代码

3.1 jndi.properties

要连接到队列,必然需要一些相关的参数,比如:队列地址、用户名、密码、连接“字符串”等,如果硬编码在java代码中,显然不好,我们可以在src目录下,新建一个jndi.properties文件,内容参考下图:

java.naming.factory.initial=org.jboss.naming.remote.client.InitialContextFactory

java.naming.provider.url=remote\://localhost\:4447

java.naming.security.principal=msgUser

java.naming.security.credentials=Password1!

lookup.connectionfactory.name=jms/RemoteConnectionFactory

lookup.destination.name=queue/mytest

前面java开头是的必须的,后面的二行,是我自己加的(当然大家也可以自行添加任何需要的属性)

3.2 编写测试代码

(以下代码是在jboss-quickstart示例代码的基础上修改而来的)

 1 package org.jboss.as.quickstarts.jms;
 2 
 3 import java.util.Hashtable;
 4 
 5 import javax.jms.Connection;
 6 import javax.jms.ConnectionFactory;
 7 import javax.jms.Destination;
 8 import javax.jms.JMSException;
 9 import javax.jms.MessageConsumer;
10 import javax.jms.MessageProducer;
11 import javax.jms.Session;
12 import javax.jms.TextMessage;
13 import javax.naming.Context;
14 import javax.naming.InitialContext;
15 import javax.naming.NamingException;
16 
17 
18 
19 public class JbossJMSTest {
20 
21     public static void main(String[] args) throws NamingException, JMSException {
22 
23         final String lOOKUP_CONNECTION_FACTORY_NAME = "lookup.connectionfactory.name";
24         final String lOOKUP_DESTINATION_NAME = "lookup.destination.name";
25 
26         ConnectionFactory connectionFactory = null;
27         Connection connection = null;
28         Session session = null;
29         MessageProducer producer = null;
30         MessageConsumer consumer = null;
31         Destination destination = null;
32         TextMessage message = null;
33         Context context = null;
34 
35         try {
36             // 创建上下文(默认会从应用的classpath下加载jndi.properties做为环境参数)
37             context = new InitialContext();
38 
39             // 把环境参数取出来,后面会用到
40             Hashtable<String, String> env = (Hashtable<String, String>) context
41                     .getEnvironment();
42 
43             // 查找连接工厂
44             connectionFactory = (ConnectionFactory) context.lookup(env
45                     .get(lOOKUP_CONNECTION_FACTORY_NAME));
46 
47             // 查找目标队列
48             destination = (Destination) context.lookup(env
49                     .get(lOOKUP_DESTINATION_NAME));
50 
51             // 创建连接
52             connection = connectionFactory.createConnection(
53                     env.get(Context.SECURITY_PRINCIPAL),
54                     env.get(Context.SECURITY_CREDENTIALS));
55 
56             // 创建会话
57             session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
58 
59             // 创建生产者(即发送者)
60             producer = session.createProducer(destination);
61 
62             // 创建消费者(即接收者)
63             consumer = session.createConsumer(destination);
64 
65             // 开始连接
66             connection.start();
67 
68             // 发送消息
69             message = session.createTextMessage("菩提树下的杨过,欢迎使用JMS!");
70             producer.send(message);
71 
72             // 接收消息
73             message = (TextMessage) consumer.receive(5000);
74 
75             // 打印消息
76             System.out.println(message.getText());
77 
78         } catch (NamingException e) {
79             e.printStackTrace();
80         } catch (JMSException e) {
81             e.printStackTrace();
82         } finally {
83             // 释放资源
84             if (context != null) {
85                 context.close();
86             }
87 
88             if (connection != null) {
89                 connection.close();
90             }
91 
92         }
93     }
94 
95 }

运行结果:

最后附加上pom.xml内容:

 1 <?xml version="1.0"?>
 2 
 3 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 5     <modelVersion>4.0.0</modelVersion>
 6 
 7     <groupId>cnblogs</groupId>
 8     <artifactId>helloworld-jms</artifactId>
 9     <version>1.0</version>
10     <packaging>jar</packaging>
11 
12     <properties>
13         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
14     </properties>
15 
16     <dependencies>
17         <dependency>
18             <groupId>org.jboss.as</groupId>
19             <artifactId>jboss-as-jms-client-bom</artifactId>
20             <version>7.2.0.Final-redhat-8</version>
21             <type>pom</type>
22         </dependency>
23     </dependencies>
24 
25 </project>

示例源代码下载:helloworld-jms.zip

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • jboss上的soap web service开发示例

    以下示例,由jboss quickstart示例代码得来: 一、创建一个常规的dynamic web项目,建议支持maven ,项目的关键属性参考下图: ? 二...

    菩提树下的杨过
  • JSP中的Servlet及Filter

    asp.net中,如果开发人员想自己处理http请求响应,可以利用HttpHandler来满足这一要求;类似的,如果要拦截所有http请求,可以使用HttpMo...

    菩提树下的杨过
  • puremvc框架之proxy

    上一篇 puremvc框架之Command 里,已经学习了如何利用Command来解耦View层与业务逻辑的依赖,但是仍然有二个问题: 1、ButtonMedi...

    菩提树下的杨过
  • 开机黑屏或空白屏幕?

    这种情况不会经常发生,但有时可能会出现问题,导致你的设备显示黑屏或空白屏幕。可能会导致黑屏或空白屏幕出现的一些常见情况包括:显示器连接问题、显示适配卡驱动程序更...

    BessCroft
  • Linux系统crond、rsync、打包备份数据操作实战

    前面介绍了系统中定时任务、rsync、打包等各种操作,同时也介绍了实际生产环境中的各类案例,今天我们结合这几种功能做一次实战(备份数据)

    民工哥
  • 记一次Navicat for MySQL 10060错误的解决过程

    最近加班挺多,所以也好久没远程访问自己云服务器上的MySQL数据库了。今天本地启动Node服务时连不上MySQL,照常用Navicat For MySQL连接远...

    Tusi
  • 您有一份网易云音乐产品分析报告,请注意查收~

    本文从市场情况、产品概述、用户分析、核心模块、用户反馈五个维度,对网易云音乐(iOS v4.3.5)进行浅析。

    CDA数据分析师
  • 洛谷P4561 [JXOI2018]排序问题(二分 期望)

    一次排好的概率是个数数题,他等于一次排好的方案除以总方案,也就是\(\frac{\prod cnt_{a_i}!}{(n+m)!}\)。因为最终的序列是一定的,...

    attack
  • k8s采坑记 - 解决二进制安装环境下证书过期问题

    当你的kubernetes报错:certificate has expired or is not yet valid,可以通过命令:openssl x509 ...

    justmine
  • 你所了解的三层交换机,是这样工作的

    为什么我们说三层交换机的三层转发性能要比路由器的效率要高的多?有时候在很多书里会提及到现在路由器的软件做的也非常强大,几乎也能够达到限速转发的能力;但是软件能够...

    SDNLAB

扫码关注云+社区

领取腾讯云代金券