?? messageclient.java
字號:
//消息客戶端程序
package examples.Message;
import javax.jms.*;
import javax.naming.*;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class MessageClient {
public static void main(String[] args) {
Context jndiContext = null;
QueueConnectionFactory queueConnectionFactory = null;
QueueConnection queueConnection = null;
QueueSession queueSession = null;
Queue queue = null;
QueueSender queueSender = null;
MapMessage message = null;
final int NUM_MSGS;
//獲取JNDI上下文,同時查看連接factory和隊列
try {
jndiContext = new InitialContext();
Object tmp = jndiContext.lookup("ConnectionFactory");
queueConnectionFactory = (QueueConnectionFactory) tmp;
jndiContext.lookup("java:comp/env/QueueConnectionFactory");
queue = (Queue) jndiContext.lookup("queue/A");
} catch (NamingException e) {
System.out.println("JNDI lookup failed: " + e.toString());
System.exit(1);
}
//通過連接創建會話。創建發送者和映射消息。
//發送消息,同時對文本進行少量修改
//發送end-of-messages消息,最后關閉連接
try {
//創建連接
queueConnection = queueConnectionFactory.createQueueConnection();
//通過連接創建會話
queueSession =queueConnection.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
queueConnection.start();
//創建發送者
queueSender = queueSession.createSender(queue);
//創建Map映射消息
message = queueSession.createMapMessage();
//定義一些Name/Value對
message.setString ("OrderID", "1");
message.setInt ("ItemID", 5);
message.setInt ("Quantity", 50);
message.setDouble ("UnitPrice", 5.00);
message.setString ("emailID", "jwu@webjet.com.cn");
//發送消息
queueSender.send (message);
} catch (JMSException e) {
System.out.println("Exception occurred: " + e.toString());
}
finally {
if (queueConnection != null) {
try {
queueConnection.close();
} catch (JMSException e) {}
}
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -