Jboss+esb+实例开发文档Word格式.docx
- 文档编号:5742797
- 上传时间:2023-05-05
- 格式:DOCX
- 页数:16
- 大小:244.99KB
Jboss+esb+实例开发文档Word格式.docx
《Jboss+esb+实例开发文档Word格式.docx》由会员分享,可在线阅读,更多相关《Jboss+esb+实例开发文档Word格式.docx(16页珍藏版)》请在冰点文库上搜索。
点击“finish”完成。
项目结构图如下所示:
2)服务器可以选择JBOSS或者ESBServer
创建jboosserver:
点击"
Preferences"
找到“server”选项,然后点击"
runtimeEnviroments"
如下图所示:
点击“add”按钮,出现如下图所示:
选择Jbosscommunity->
Jboss4.2Runtime点击“next”
选择HomeDirectory选择JbossEsb路径和JRE“Finish”然后完成就可以了。
3)写测试代码
项目包结构如下图所示:
(1)首先在esbcontent/META-INF下新建一个配置文件:
jboss-esb.xml
输入如下内容:
<
?
xmlversion="
1.0"
encoding="
UTF-8"
>
jbossesb
xmlns="
xmlns:
xsi="
http:
//www.w3.org/2001/XMLSchema-instance"
xsi:
schemaLocation="
http:
//anonsvn.jboss.org/repos/labs/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd"
parameterReloadSecs="
5"
<
providers>
<
jms-providername="
JBossMQ"
connection-factory="
ConnectionFactory"
<
jms-busbusid="
quickstartGwChannel"
<
jms-message-filterdest-type="
QUEUE"
dest-name="
queue/quickstart_helloworld_Request_gw"
/>
/jms-bus>
quickstartEsbChannel"
queue/quickstart_helloworld_Request_esb"
/jms-provider>
/providers>
services>
servicecategory="
FirstServiceESB"
name="
SimpleListener"
description="
HelloWorld"
listeners>
jms-listenername="
JMS-Gateway"
busidref="
is-gateway="
true"
helloWorld"
/listeners>
actionsmep="
OneWay"
actionname="
action1"
class="
org.jboss.soa.esb.samples.quickstart.helloworld.MyJMSListenerAction"
process="
displayMessage"
/actions>
/service>
/services>
/jbossesb>
类中的Action的路径根据自己的需要自己修改。
(2)新建MyJMSListenerAction类
packageorg.jboss.soa.esb.samples.quickstart.helloworld;
importorg.jboss.soa.esb.actions.AbstractActionLifecycle;
importorg.jboss.soa.esb.helpers.ConfigTree;
importorg.jboss.soa.esb.message.Message;
/**
*jboss_esb开发
*@authorsu_jian
*/
publicclassMyJMSListenerActionextendsAbstractActionLifecycle{
protectedConfigTree_config;
publicMyJMSListenerAction(ConfigTreeconfig){
_config=config;
}
publicMessagedisplayMessage(Messagemessage)throwsException{
System.out.println("
接受到的message是:
"
+message.getBody().get());
returnmessage;
}
(3)在esbcontent目录下新建:
jbm-queue-service.xml
xmlversion="
encoding="
server>
mbeancode="
org.jboss.jms.server.destination.QueueService"
jboss.esb.quickstart.destination:
service=Queue,name=quickstart_helloworld_Request_esb"
xmbean-dd="
xmdesc/Queue-xmbean.xml"
dependsoptional-attribute-name="
ServerPeer"
jboss.messaging:
service=ServerPeer<
/depends>
depends>
service=PostOffice<
/mbean>
service=Queue,name=quickstart_helloworld_Request_gw"
/server>
(4)最后新建esb部署文件deployment.xml在META-INF文件夹下:
jbossesb-deployment>
service=Queue,name=quickstart_helloworld_Request_esb<
service=Queue,name=quickstart_helloworld_Request_gw<
/jbossesb-deployment>
发布工程到jboss服务器,并启动服务器:
(5)新建测试类
如下图所示就可以发布了。
然后新建测试类
importjava.util.Properties;
importjavax.jms.JMSException;
importjavax.jms.ObjectMessage;
importjavax.jms.Queue;
importjavax.jms.QueueConnection;
importjavax.jms.QueueConnectionFactory;
importjavax.jms.QueueSender;
importjavax.jms.QueueSession;
importjavax.naming.Context;
importjavax.naming.InitialContext;
importjavax.naming.NamingException;
*jboss_esb测试类
publicclassSendJMSMessage{
QueueConnectionconn;
QueueSessionsession;
Queueque;
publicvoidsetupConnection()throwsJMSException,NamingException
{
Propertiesproperties1=newProperties();
properties1.put(Context.INITIAL_CONTEXT_FACTORY,
org.jnp.interfaces.NamingContextFactory"
);
properties1.put(Context.URL_PKG_PREFIXES,
org.jboss.naming:
org.jnp.interfaces"
properties1.put(Context.PROVIDER_URL,"
jnp:
//127.0.0.1:
1099"
InitialContextiniCtx=newInitialContext(properties1);
Objecttmp=iniCtx.lookup("
QueueConnectionFactoryqcf=(QueueConnectionFactory)tmp;
conn=qcf.createQueueConnection();
que=(Queue)iniCtx.lookup("
session=conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
conn.start();
ConnectionStarted"
publicvoidstop()throwsJMSException
conn.stop();
session.close();
conn.close();
publicvoidsendAMessage(Stringmsg)throwsJMSException{
QueueSendersend=session.createSender(que);
ObjectMessagetm=session.createObjectMessage(msg);
send.send(tm);
send.close();
publicstaticvoidmain(Stringargs[])throwsException
SendJMSMessagesm=newSendJMSMessage();
sm.setupConnection();
sm.sendAMessage("
这里是发送的消息"
//这里输入消息文本
sm.stop();
(6)运行新建的测试类可以看到启动的jboss服务器中出现如下所示信息:
11:
28:
15,765INFO[STDOUT]接受到的message是:
这里是发送的消息
则表明调用成功!
OK
- 配套讲稿:
如PPT文件的首页显示word图标,表示该PPT已包含配套word讲稿。双击word图标可打开word文档。
- 特殊限制:
部分文档作品中含有的国旗、国徽等图片,仅作为作品整体效果示例展示,禁止商用。设计者仅对作品中独创性部分享有著作权。
- 关 键 词:
- Jboss esb 实例 开发 文档