`

(转)JBOSS7.1下开发JMS(HoernetQ)的示例DEMO

阅读更多

1.首先是要add-user.bat,添加用户,在jboss的bin目录下运行add-user.bat

 

角色是guest不是gutst。照样添加就可以了.之后就是一路yes敲下去.

2.替换XML文件,CMD命令我用的不熟,折腾半天也没运行起JBOSS,伤心之余就跑去更换JBOSS的启动使用的XML文件了.D:\software\jboss-as-7.1.3.Final\standalone\configuration文件夹下,默认使用standalone.xml,你把他备份好,然后把standalone-full.xml的名字改为standalone.xml.因为那个啥,JBOSS7默认是没带JMS的.

3.修改Jboss配置文件standalone-full.xml(也就是现在的standalone.xml),找到hornetq-server节点,在该节点下的jms-destinations确定含有以下配置.

 

1
2
3
4
5
6
7
8
9
10
<jms-destinations>
                    <jms-queue name="testQueue">
                        <entry name="queue/test"/>
                        <entry name="java:jboss/exported/jms/queue/test"/>
                    </jms-queue>
                    <jms-topic name="ServerNotificationTopic">
                        <entry name="topic/ServerNotification"/>
                        <entry name="java:jboss/exported/jms/topic/ServerNotification"/>
                    </jms-topic>
                </jms-destinations>

没就加上.

4.进入JBOSS控制台,看到JMS就是正确的了.擦,我的standalone.bat无法运行..才发现.不过Eclipse运行貌似一点问题没,JBOSS TOLL插件我全装了,汗.如图:


5.开始写代码,我都是写的main方法.注意把D:\software\jboss-as-7.1.3.Final\bin\client下的jar包弄上.

第一个是客户端的消息生产者:

 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package org.credo.jms;
 
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;
import java.util.Properties;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
 
/**
 * <p>Description:JMS客户端消息生产者 </p>
 */
public class JMSProducer {
    private static final Logger log = Logger.getLogger(JMSProducer.class.getName());
 
    private static final String DEFAULT_MESSAGE = "the 4 message!";
    // xml文件272行
    private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory";
    // xml文件293行,初次找JBOSS的JNDI太不容易了
    private static final String DEFAULT_DESTINATION = "jms/queue/test";
    private static final String DEFAULT_MESSAGE_COUNT = "1";
 
    private static final String DEFAULT_USERNAME = "lion";
    private static final String DEFAULT_PASSWORD = "123456";
    private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";
    private static final String PROVIDER_URL = "remote://localhost:4447";
 
    public static void main(String[] args) throws Exception {
        Context context=null;
        Connection connection=null;
        try {
            // 设置上下文的JNDI查找
            log.info("设置JNDI访问环境信息也就是设置应用服务器的上下文信息!");
            final Properties env = new Properties();
            env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);// 该KEY的值为初始化Context的工厂类,JNDI驱动的类名
            env.put(Context.PROVIDER_URL,  PROVIDER_URL);// 该KEY的值为Context服务提供者的URL.命名服务提供者的URL
            env.put(Context.SECURITY_PRINCIPAL, DEFAULT_USERNAME);
            env.put(Context.SECURITY_CREDENTIALS, DEFAULT_PASSWORD);//应用用户的登录名,密码.
            // 获取到InitialContext对象.
            context = new InitialContext(env);
            log.info("初始化上下文,'JNDI驱动类名','服务提供者URL','应用用户的账户','密码'完毕.");
 
            log.info("获取连接工厂!");
            ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup(DEFAULT_CONNECTION_FACTORY);
            log.info("获取目的地!");
            Destination destination = (Destination) context.lookup(DEFAULT_DESTINATION);
 
            // 创建JMS连接、会话、生产者和消费者
            connection = connectionFactory.createConnection(DEFAULT_USERNAME, DEFAULT_PASSWORD);
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(destination);
            connection.start();
 
            int count = Integer.parseInt(DEFAULT_MESSAGE_COUNT);
            // 发送特定数目的消息
            TextMessage message = null;
            for (int i = 0; i < count; i++) {
                message = session.createTextMessage(DEFAULT_MESSAGE);
                producer.send(message);
                log.info("message:"+message);
                log.info("message:"+DEFAULT_MESSAGE);
            }
            // 等待30秒退出
            CountDownLatch latch = new CountDownLatch(1);
            latch.await(30, TimeUnit.SECONDS);
             
        } catch (Exception e) {
            log.severe(e.getMessage());
            throw e;
        } finally {
            if (context != null) {
                context.close();
            }
            // 关闭连接负责会话,生产商和消费者
            if (connection != null) {
                connection.close();
            }
        }
    }
}

每次运行后如图:


JBOSS端如图所示:


每次向JBOSS的Queue发送消息成功的话,上面红圈的数字都会+1.

如果电脑重启,JBOSS重启,消息仍然是存在的.如果被接收了的话,消息就是消失.

2.客户端消费者代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package org.credo.jms;
 
import java.util.Properties;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
 
public class JMSConsumer {
    private static final Logger log = Logger.getLogger(JMSConsumer.class.getName());
 
    private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory";
    private static final String DEFAULT_DESTINATION = "jms/queue/test";
    private static final String DEFAULT_USERNAME = "lion";
    private static final String DEFAULT_PASSWORD = "123456";
    private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";
    private static final String PROVIDER_URL = "remote://localhost:4447";
 
    public static void main(String[] args) throws Exception {
 
        ConnectionFactory connectionFactory = null;
        Connection connection = null;
        Session session = null;
        MessageConsumer consumer = null;
        Destination destination = null;
        TextMessage message = null;
        Context context = null;
 
        try {
            final Properties env = new Properties();
            env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);
            env.put(Context.PROVIDER_URL, PROVIDER_URL);
            env.put(Context.SECURITY_PRINCIPAL, DEFAULT_USERNAME);
            env.put(Context.SECURITY_CREDENTIALS, DEFAULT_PASSWORD);
            context = new InitialContext(env);
 
            connectionFactory = (ConnectionFactory) context.lookup(DEFAULT_CONNECTION_FACTORY);
            destination = (Destination) context.lookup(DEFAULT_DESTINATION);
 
            connection = connectionFactory.createConnection(DEFAULT_USERNAME, DEFAULT_PASSWORD);
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            consumer = session.createConsumer(destination);
            connection.start();
 
            // 等待30秒退出
            CountDownLatch latch = new CountDownLatch(1);
            while (message == null) {
                log.info("开始从JBOSS端接收信息-----");
                message = (TextMessage) consumer.receive(5000);
                latch.await(1, TimeUnit.SECONDS);
            }
            log.info("接收到的消息的内容:" + message.getText());
        } catch (Exception e) {
            log.severe(e.getMessage());
            throw e;
        } finally {
            if (context != null) {
                context.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }
}

 

 

 

然后继续看JBOSS的控制台,可以发现消息减少了一条.

参考自:http://lym6520.iteye.com/blog/1600630

分享到:
评论

相关推荐

    JBoss7.1下EJB入门范例代码

    总结起来,这个示例涵盖了 EJB 在 JBoss 7.1 下的基础使用,包括 EJB 的创建、部署、远程调用以及 Web 客户端的交互。通过学习这个示例,你可以了解如何在实际项目中利用 JBoss 提供的企业级功能来构建可扩展且可靠...

    jboss7.1wwww

    - JBoss 7.1与Eclipse、IntelliJ IDEA等IDE集成良好,提供了丰富的开发和调试工具,例如JBoss Developer Studio,使得开发和调试过程更为便捷。Tomcat虽然也有相应的开发工具,但集成程度和功能上可能稍逊一筹。 6...

    jboss7.1+ejb3.1建立第一个Ejb项目

    安装JDK以支持Java编程,Eclipse3.7作为集成开发环境,以及JBoss7.1作为应用服务器。确保所有软件都已正确下载并解压到适当位置。 接下来,你需要在Eclipse中安装JBoss Tools。这是Eclipse的一组插件,提供对JBoss...

    Jboss7.1安装配置(linux环境)

    Jboss7.1安装配置(linux环境)

    jboss 7 配置 jms

    **JBoss 7 配置 JMS 知识点详解** JBoss Application Server(简称 JBoss AS)是一款开源的企业级 Java 应用服务器,由 Red Hat 公司维护。JBoss 7 是其一个重要的版本,它引入了许多新特性和性能优化。在 JBoss 7 ...

    jboss7.1 linux版本

    JBoss AS 7.1.0.Final是在Linux环境下运行的一款开源Java应用服务器,由Red Hat公司维护。这个版本发布于2012年,它引入了许多改进和新特性,旨在提供更快的启动速度、更高的性能以及更好的模块化。在这个环境中,...

    linux 下部署JBOSS 7.1 配置.doc

    linux 下部署JBOSS 7.1 配置.doc

    jboss7.1-Examples:具有JBOSS 7.1的EJB 2示例

    【标题】"jboss7.1-Examples"涵盖了基于JBOSS 7.1 Application Server (AS) 的EJB 2.1应用实例。EJB(Enterprise JavaBeans)是Java EE平台的核心组件之一,用于构建可扩展、安全且可靠的分布式企业级应用。JBOSS ...

    linux下部署JBOSS7.1配置.pdf

    linux下部署JBOSS7.1配置.pdf

    JBPM教程第三部分、(使用JBOSS7.1及对JBPM5.4事件学习01)

    【JBPM教程第三部分:使用JBOSS7.1及对JBPM5.4事件学习】 JBPM(Java Business Process Management)是一个开源的工作流和业务流程管理框架,它允许开发者和业务分析师创建、执行和监控复杂的业务流程。在这个教程...

    springmvc3注解+mybatis+JTA+jboss7.1下多个数据源配置(一)

    在本教程中,我们将深入探讨如何在Spring MVC 3中结合MyBatis并利用JTA(Java Transaction API)以及JBoss 7.1应用程序服务器来配置多数据源环境。这个配置对于那些需要处理多个数据库或者分布式事务的项目来说至关...

    JBoss_Application_Server_7.1官方文档

    JBoss Application Server 7.1是Red Hat公司推出的一款开源应用服务器,它是基于Java EE(Enterprise Edition)平台的,能够支持各种企业级应用的部署和运行。这份官方文档详细介绍了JBoss AS 7.1的功能、配置、管理...

    jboss服务器下的jms实例

    【JBoss 服务器下的 JMS 实例】 Java 消息服务 (JMS) 是 Java 平台中用于处理异步消息传递的标准API,它在面向服务架构 (SOA) 中扮演着关键角色,特别是在需要与外部系统进行异步通信的企业环境中。JBoss 服务器...

    linux下部署JBOSS7.1配置.doc

    在Linux环境下部署JBoss 7.1.1涉及到多个步骤,包括系统设置、JDK安装、JBoss AS(Application Server)的部署以及环境变量的配置。以下是对整个过程的详细解释: 1. **系统准备**: - 操作系统:CentOS 6.3 Final...

    linux下部署JBOSS7.1配置借鉴.pdf

    在本文中,我们将深入探讨如何在Linux环境下,特别是CentOS 6.3 32位系统上部署和配置JBoss Application Server 7.1.1。首先,确保您的系统满足必要的软件需求,包括Linux内核版本2.6.32-279.el6.i686,Oracle Java ...

    JBoss7.1.1配置指南及管理员手册PDF版

    - **安全配置**:介绍了JBoss7.1的安全补充说明,这部分内容对于确保应用服务器的安全运行至关重要。 ### 管理JBoss7 - **运行模式**:JBoss7支持单服务器模式和管理域模式。管理员应了解如何在不同模式下部署和...

    Jboss7.1.1p配置mysql和oracle以及项目调用参照.pdf

    3. **修改standalone.xml**:接着需要修改位于“D:\jboss7.1\standalone\configuration”目录下的standalone.xml文件,以便配置MySQL和Oracle的数据源。 - **原数据源配置**:原始的配置文件中包含了一个H2数据库...

Global site tag (gtag.js) - Google Analytics