- 浏览: 86923 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
518ts520:
03:07:24,852 INFO [ServiceInvo ...
JBoss ESB学习笔记16——第十五个ESB应用Web Service Consumer 1 -
dy.f:
你理解错误了,selector="type='fro ...
JBoss ESB学习笔记5——第四个ESB应用Hello World File Action -
xiaoshalou_2002:
错误贴上 。Exception in thread &q ...
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World -
xiaoshalou_2002:
我这边16个例子中的客户端运行都出错,是少了 ...
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World -
qianyang:
ligenhang 写道我部署也报java.lang.Runt ...
JBoss ESB学习笔记2——第一个ESB应用Hello World
续上篇介绍了第二个ESB应用,本文介绍第三个ESB应用——Hello World Notification。
说明:本文及后续文章虽非百分百的原创,但毕竟包含本人的努力和付出,所以希望大家转载时务请注明出处:http://yarafa.iteye.com,谢谢合作。
1 概述
该实例主要演示了Notifier的使用,当ESB接收到来自客户端的消息后,自动向指定的地址发送通知,这里的地址可以是控制台,文件,消息队列或者消息主题。
在下面的例子中,需要定义两个消息队列,一个接收来自客户端的消息,第二个用作ESB内部Message通道。此外,还有一个消息主题,用于接收ESB发来的通知。
2 新建ESB工程
操作过程略。
3 ESB配置
3.1 创建消息队列和消息主题
如概述中所描述,这里将创建两个消息队列和一消息主题。在esbcontent文件夹下创建文件jbm-queue-service.xml用于配置消息队列,内容如下:
<?xml version="1.0" encoding="UTF-8"?> <server> <mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.helloworld.destination:service=Queue,name=helloworldNofityEsb" xmbean-dd="xmdesc/Queue-xmbean.xml"> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer </depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> <mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.helloworld.destination:service=Queue,name=helloworldNofityGw" xmbean-dd="xmdesc/Queue-xmbean.xml"> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer </depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> <mbean code="org.jboss.jms.server.destination.TopicService" name="jboss.esb.helloworld.destination:service=Topic,name=helloworldTopic" xmbean-dd="xmdesc/Topic-xmbean.xml"> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer </depends> <attribute name="SecurityConfig"> <security> <role name="guest" read="true" write="true" create="true" /> </security> </attribute> </mbean> </server>
3.2 定义Provider
这里将定义一个JMS Provider,同时定义两个消息通道,一个用于监听客户端发来的消息,另一个用作ESB消息通道。内容如下:
<jms-provider connection-factory="ConnectionFactory" name="JBossMQ"> <jms-bus busid="helloworldNotifyChanel"> <jms-message-filter dest-name="queue/helloworldNofityGw" dest-type="QUEUE" /> </jms-bus> <jms-bus busid="helloworldNotifyEsbChanel"> <jms-message-filter dest-name="queue/helloworldNofityEsb" dest-type="QUEUE" /> </jms-bus> </jms-provider>
3.3 定义Service
<service category="HelloWorldNotify" description="Hello World Notify" name="HelloWorldNotifyService"> <listeners /> <actions / </service>
3.4 定义Listener
这里定义两个listener,分别用于监听客户端消息和ESB内部消息。其中,前者用于监听客户端消息,因此需要将其is-gateway属性设置为true。
<jms-listener busidref="helloworldNotifyChanel" is-gateway="true" name="helloWorldNotifier" /> <jms-listener busidref="helloworldNotifyEsbChanel" name="helloWorldNotifierEsb" />
3.5 配置Action
<actions mep="OneWay"> <action class="org.jboss.soa.esb.actions.Notifier" name="notificationAction"> <property name="okMethod" value="notifyOK" /> <property name="notification-details"> <NotificationList type="ok"> <target class="NotifyConsole" /> <target class="NotifyFiles"> <file URI="file:///F:\Workspace\Eclipse-JEE\helloworldtopicnitify\test.txt" append="true" /> </target> <target class="NotifyTopics"> <topic jndiName="topic/helloworldTopic" /> </target> </NotificationList> </property> </action> </actions>
配置说明:这里的action调用JBoss ESB提供的Notifier类来实现处理逻辑。这里的通知目的地有两个,一个是文件系统,另一个是消息主题topic/helloworldTopic。其中,对于文件系统通知,append属性表示是否在接收到来自客户端的消息后,将消息内容追加到文件的末尾。
3.6 配置部署文件
部署依赖文件deployment.xml内容如下:
<jbossesb-deployment> <depends>jboss.esb.helloworld.destination:service=Queue,name=helloworldNofityGw </depends> <depends>jboss.esb.helloworld.destination:service=Topic,name=helloworldTopic </depends> </jbossesb-deployment>
3.7 部署ESB
将整个工程导出成一个ESB文件,并保存至JBoss ESB Server的部署目录下,启动JBoss ESB Server即可。
4 ESB客户端
4.1 新建Java工程
这里略去操作过程以及添加所需要的Jar包,具体操作过程可参考第一个ESB实例说明。
4.2 发送消息的客户端
/*********************************************************************** * <p>Project Name: helloworldclient</p> * <p>File Name: com.thu.afa.esb.jbossesb.client.HelloWorldNotifyClient.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.client; import java.util.Properties; import javax.jms.ObjectMessage; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.naming.Context; import javax.naming.InitialContext; /** * <p>Class Name: HelloWorldNotifyClient</p> * <p>Description: </p> * @author Afa * @date 2010-9-9 * @version 1.0 */ public class HelloWorldNotifyClient { private QueueConnection connection; private QueueSession session; private Queue queue; public void setupConnection() throws Exception { Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); properties.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces"); properties.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099"); InitialContext context = new InitialContext(properties); QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup("ConnectionFactory"); connection = factory.createQueueConnection(); //queue = (Queue) context.lookup("queue/helloworldRequest"); queue = (Queue) context.lookup("queue/helloworldNofityGw"); session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); connection.start(); System.out.println("Connection Started"); } public void stop() throws Exception { if(connection != null) connection.stop(); if(session != null) session.close(); if(connection != null) connection.close(); } public void sendAMessage(String text) throws Exception { QueueSender sender = session.createSender(queue); ObjectMessage message = session.createObjectMessage(text); sender.send(message); sender.close(); } public static void main(String[] args) throws Exception { HelloWorldNotifyClient client = new HelloWorldNotifyClient(); client.setupConnection(); client.sendAMessage("Llu, miss you, notify, afa"); client.stop(); } }
4.3 接收消息的客户端
/*********************************************************************** * <p>Project Name: helloworldclient</p> * <p>File Name: com.thu.afa.esb.jbossesb.client.HelloWorldNotifyReceiverClient.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.client; import java.util.Properties; import javax.jms.Message; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactory; import javax.jms.TopicSession; import javax.jms.TopicSubscriber; import javax.naming.Context; import javax.naming.InitialContext; /** * <p>Class Name: HelloWorldNotifyReceiverClient</p> * <p>Description: </p> * @author Afa * @date 2010-9-9 * @version 1.0 */ public class HelloWorldNotifyReceiverClient { private TopicConnection connection; private TopicSession session; private Topic topic; private TopicConnectionFactory factory; public void setup() throws Exception { Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); properties.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces"); properties.put(Context.PROVIDER_URL, "jnp://localhost:1099"); InitialContext context = new InitialContext(properties); factory = (TopicConnectionFactory) context.lookup("ConnectionFactory"); topic = (Topic) context.lookup("topic/helloworldTopic"); connection = factory.createTopicConnection("guest", "guest"); connection.setClientID("clientid"); session = connection.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE); connection.start(); } public void receiveMessage() throws Exception { TopicSubscriber subscriber = session.createSubscriber(topic); Message message = subscriber.receive(); if(message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("Notification Infomation: " + textMessage.getText()); } subscriber.close(); } public void stop() throws Exception { if(connection != null) connection.stop(); if(session != null) session.close(); if(connection != null) connection.close(); } /** * <p>Title: </p> * <p>Method Name: main</p> * <p>Description: </p> * @author: Afa * @date: 2010-9-9 * @param args */ public static void main(String[] args) throws Exception { HelloWorldNotifyReceiverClient client = new HelloWorldNotifyReceiverClient(); client.setup(); client.receiveMessage(); client.stop(); } }
首先运行接收消息的客户端,然后运行发送消息的客户端,即可在F:\Workspace\Eclipse-JEE\helloworldtopicnitify\test.txt文件中看到客户端发来的消息内容。另一方面,由于已经运行了接收消息的客户端,所以可以同时在该客户端的控制台看到通知信息,如下图所示,其中,文本文件中有三条来自客户端的消息(执行了三次发消息操作),这是在配置ESB时由append属性指定的。
上述便是ESB第三个应用实例。如有问题,欢迎指正。
-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Jan 3rd, 2011
-----------------------------------------------------
评论
而上个例子中却要定义heloworldEsb ?
正如1楼说的一样
发表评论
-
JBoss ESB学习笔记16——第十五个ESB应用Web Service Consumer 1
2011-04-15 21:06 3215续上篇介绍了第十四个ESB应用,本文介绍第十五个ESB应用—— ... -
JBoss ESB学习笔记15——第十四个ESB应用Transform XML to POJO
2011-04-12 13:09 1994续上篇介绍了第十三个ESB应用,本文介绍第十四个ESB应用—— ... -
JBoss ESB学习笔记14——第十三个ESB应用Transform CSV to XML
2011-04-09 13:12 1943续上篇介绍了第十二个ESB应用,本文介绍第十三个ESB应用—— ... -
JBoss ESB学习笔记13——第十二个ESB应用Spring AOP
2011-04-03 11:42 1564续上篇介绍了第十一个ESB应用,本文介绍第十二个ESB应用—— ... -
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World
2011-04-01 15:27 2277续上篇介绍了第十个ESB应用,本文介绍第十一个ESB应用——S ... -
JBoss ESB学习笔记11——第十个ESB应用Message Filters
2011-03-29 20:35 1920续上篇介绍了第九个ESB应用,本文介绍第十个ESB应用——Me ... -
JBoss ESB学习笔记10——第九个ESB应用JMS Topic
2011-03-26 21:14 2317续上篇介绍了第八个ESB应用,本文介绍第九个ESB应用——JM ... -
JBoss ESB学习笔记9——第八个ESB应用JMS Router
2011-03-11 21:16 2506续上篇介绍了第七个ESB应用,本文介绍第八个ESB应用——JM ... -
JBoss ESB学习笔记8——第七个ESB应用Https Gateway
2011-03-05 11:29 2492续上篇介绍了第六个ESB应用,本文介绍第七个ESB应用——Ht ... -
JBoss ESB学习笔记7——第六个ESB应用Http Gateway
2011-02-26 10:45 3425续上篇介绍了第五个ESB应用,本文介绍第六个ESB应用——Ht ... -
JBoss ESB学习笔记6——第五个ESB应用Custom Action
2011-01-15 10:34 2211续上篇介绍了第四个ESB应用,本文介绍第五个ESB应用——Cu ... -
JBoss ESB学习笔记5——第四个ESB应用Hello World File Action
2011-01-08 11:23 2585续上篇介绍了第三个ESB应用,本文介绍第四个ESB应用——He ... -
JBoss ESB学习笔记3——第二个ESB应用Hello World Action
2010-12-21 22:20 3772续上篇介绍了第一个ESB应用,本文介绍第二个ESB应用——He ... -
JBoss ESB学习笔记2——第一个ESB应用Hello World
2010-12-13 20:34 6517续上文搭建好开发环境后就可以开发ESB应用了。本文介绍第一个E ... -
JBoss ESB学习笔记1——搭建ESB开发环境
2010-12-12 13:55 7702最近由于工作需要用到 ...
相关推荐
4——第三个ESB代码Hello World Notification 38 5——第四个ESB代码Hello World File Action 45 6——第五个ESB代码Custom Action 51 7——第六个ESB代码Http Gateway 63 8——第七个ESB代码Https Gateway 74 9——...
JBossESB学习笔记 收集了网上1-16系列教程,笔记详细介绍了JBossESB各个组件的特性及配置文件的说明
Jboss_ESB学习笔记以及总结和实例
Jboss_ESB学习笔记,介绍的很详细,可以作为入门文档来看。
jboss esb 实例及讲解,我收集的资料整理做成书
Jboss_ESB学习笔记.doc
一、Jboss ESB的简介 1、 什么是ESB。 ESB的全称是Enterprise Service Bus,即企业服务总线。ESB是过去消息中间件的发展,ESB采用了“总线”这样一种模式来管理和简化应用之间的集成拓扑结构,以广为接受的开放...
JBoss ESB新手指南 / JBoss ESB Beginners Guide。 一本很好的jboss esb入门书籍。
jbossesb开发手册,适合初学者学习使用
JBoss ESB 入门例子。主要是一个Server和一个Client。
5. 第三章 什么时候使用JBossESB 18 5.1. 介绍 18 6. 第四章 JBossESB 21 6.1. Rosetta 21 6.2. JBossESB的核心 22 6.3. JBossESB的组件 23 6.4. 配置 23 6.5. 消息存储 24 6.6. ESB-aware和ESB-unaware用户 25 6.7....
NULL 博文链接:https://siye1982.iteye.com/blog/592400
JBOSS_Esb学习资料包含各种基础学习资料与协议交互资料
ESB应用Hello_World_Notification
JBoss ESB Beginner's Guide
。。。
1.JBossESB的总体要求和我们应采取的架构方法的纲要。2.JBossESB的主要目的是提供一个部署,运行和管理的SOA基础结构。 3.SOA原则将贯穿于整个架构,而传统意义上ESB可能是它所提供功能的一狭小部分
中文版,简易介绍 JBOSS ESB的说明文档.
这些解决方案中包含了NAVTEQ 公司提供的服务以及第三方服务,以客户要求的方式交付组合服务和内容,这些方式包括Web services,WAP,portals等。 VMS在响应庞大的销售机会和预见未来客户需求方面面临着一些挑战。...
JbossESB开发环境配置.docxJbossESB开发环境配置.docx