最简单的JMS程序
下面所给的一个程序是最简单的jms程序，万事开头难，这个jsp程序虽然简单，但能够测试出目前jms环境是否正常。它使用的是jboss-3.2.3默认的环境配置。
我自己就吃过不少亏，改了半天程序，后来才发现其实并不是程序的问题，而是开发环境的问题。
<%@ page contentType="text/html; charset=GB18030" %>
<%@ page import="java.util.*, javax.naming.*, javax.jms.*" %>
<html>
<head>
<title>chat</title>
</head>
<body bgcolor="#ffffff"]
<h1>Chat</h1>
<%
String msgBody;
Context iniCtx = new InitialContext();
Queue queue = (Queue)iniCtx.lookup ("queue/testQueue");
Object tmp = iniCtx.lookup("UIL2ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
QueueConnection conn = qcf.createQueueConnection();
QueueSession qsession = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
conn.start();
QueueSender sender = qsession.createSender(queue);
TextMessage textmsg = qsession.createTextMessage();
msgBody = "Hello, hofman said.";
textmsg.setText("Test jms"+"发送了一次消息,"+msgBody);
textmsg.setStringProperty("name","coffee");
sender.send(textmsg);
QueueReceiver receiver = qsession.createReceiver(queue,"name = 'coffee'");
Message msg = receiver.receive(500);
if(msg instanceof TextMessage){
out.println(((TextMessage)msg).getText());
}
sender.close();
receiver.close();
conn.stop();
qsession.close();
conn.close();
%>
</body>
</html>
我自己就吃过不少亏，改了半天程序，后来才发现其实并不是程序的问题，而是开发环境的问题。
<%@ page contentType="text/html; charset=GB18030" %>
<%@ page import="java.util.*, javax.naming.*, javax.jms.*" %>
<html>
<head>
<title>chat</title>
</head>
<body bgcolor="#ffffff"]
<h1>Chat</h1>
<%
String msgBody;
Context iniCtx = new InitialContext();
Queue queue = (Queue)iniCtx.lookup ("queue/testQueue");
Object tmp = iniCtx.lookup("UIL2ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
QueueConnection conn = qcf.createQueueConnection();
QueueSession qsession = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
conn.start();
QueueSender sender = qsession.createSender(queue);
TextMessage textmsg = qsession.createTextMessage();
msgBody = "Hello, hofman said.";
textmsg.setText("Test jms"+"发送了一次消息,"+msgBody);
textmsg.setStringProperty("name","coffee");
sender.send(textmsg);
QueueReceiver receiver = qsession.createReceiver(queue,"name = 'coffee'");
Message msg = receiver.receive(500);
if(msg instanceof TextMessage){
out.println(((TextMessage)msg).getText());
}
sender.close();
receiver.close();
conn.stop();
qsession.close();
conn.close();
%>
</body>
</html>
hofman
2005-01-17 23:48:21
评论:0
阅读:3915
引用:0