|
Java消息发送服务(Java Messaging Service,JMS)是提供商无关的一套API,用于在程序间进行可靠的消息发送。在客户端-服务器计算中,客户端程序与服务器与服务器建立联系并请求服务。相反,消息发送应用在相互协作的程序之间发送消息。有些程序(在所谓的“对等(peer-to-peer)”应用中)则相互之间直接交换信息(JXTA使用的就是这种模型)。
现在可以用QueueSender来发送消息到队列。
4. 创建一个消息对象(Message的子类),然后使用QueueSender的发送方法将它们发送至目的地。示例程序从Session中获得一个TextMessage对象。接着示例程序将每个程序参数打包到TextMessage 中,然后使用QueueSender将其发送至队列。注意,同一个TextMessage 可以使用多次。
- TextMessage tm = qs.createTextMessage();
-
- // 为第一个参数之后的每个参数进行一次循环
- // 以文本消息的形式发送参数字符串
- for (int i = 2; i < args.length; i++) {
- tm.setText(args[i]);
- qsnd.send;
- }
5.关闭QueueConnection。在try/finally程序块的最后一条语句中关闭连接是一个好习惯。这一步很重要:忘记关闭 QueueConnections 将可能导致服务器上的资源泄漏:
- } finally {
- if (qc != null) {
- qc.close();
- }
- }
要发送消息到一个消息队列,可以使用TestQueue程序(在缺省的包中),加上一个参数“send”,例如:
$ java TestQueue send jms/queue/MyTestQueue a b c d Java Message Service 1.0.2 Reference Implementation (build b14) Sent: 'a' Sent: 'b' Sent: 'c' Sent: 'd'
1
2
下一页>>
|