「javajms例子」jms实现
本篇文章给大家谈谈javajms例子，以及jms实现对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。
本文目录一览：
谁有IBM MQ 和 java jms 的例子啊
别人弄的，我现在还在调，还没有通过。下面的代码应该没有问题
/**
* A WebSphere MQ application which uses MQQueueConnectionFactory to send msg to a Queue.
* This MQQueueConnectionFactory is looked up in JNDI Context.
* Before you look up, you should create a JNDI Context using 'WebSphere MQ JMS administration tool'.
* This method to create is provided at other file.
*/
package com.ibm.mq.test;
import java.util.Hashtable;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import com.ibm.mq.jms.MQQueueConnectionFactory;
public class MQSendByCF_JNDI {
public static void main(String[] args) {
MQSendByCF_JNDI sender = new MQSendByCF_JNDI();
try {
sender.initMQObjects();
sender.sendMsg();
} catch(Exception e) {
e.printStackTrace();
} finally {
sender.closeMQObjects();
}
}
MQQueueConnectionFactory mqcf;
QueueConnection conn;
QueueSession session;
TextMessage textMsg;
Queue queue;
QueueSender sender;
public void initMQObjects() throws Exception {
String strMsg = "Where are you?";
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY,
"com.sun.jndi.fscontext.RefFSContextFactory");
env.put(Context.PROVIDER_URL, "file:/D:/JNDI");
try {
Context ctx = new InitialContext(env);
mqcf = (MQQueueConnectionFactory) ctx.lookup("QCF_TEST");
/*This Queue [Q_TEST] is not a real queue on QebSphere MQ,
but it is binded to a real queue on WebSphere MQ.*/
queue = (Queue) ctx.lookup("Q_TEST");
} catch (NamingException e) {
System.out.println("Find MQ Objects from Context Failed.");
throw e;
}
conn = mqcf.createQueueConnection();
session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
textMsg = session.createTextMessage(strMsg);
sender = session.createSender(queue);
}
/**
* Name: sendMsg
* Date: 2010-10-1
* paramter:
* Return_type: void
* User: Leng Fuping
* Description: Send Msg
*/
public void sendMsg() throws Exception {
try {
conn.start();
} catch (JMSException e) {
System.out.println("Send Msg Failed.");
throw e;
}
sender.send(textMsg,DeliveryMode.NON_PERSISTENT,0,0);
System.out.println("Send Msg succeed.");
}
/**
* Name: closeMQObjects
* Date: 2010-10-1
* paramter:
* Return_type: void
* User: Leng Fuping
* Description: Close MQ Objects
*/
public void closeMQObjects() {
try {
if(conn != null) {
conn.stop();
}
if(sender != null) {
sender.close();
}
if(session != null) {
session.close();
}
if(conn != null) {
conn.close();
}
if(mqcf != null) {
mqcf.clear();
}
System.out.println("Close MQ objects succeed.");
} catch (JMSException e) {
System.out.println("Close MQ objects failed: " + e.getMessage());
}
}
}
jms是什么意思
Java Message Service的简称。
读音：英 [ˈdʒɑːvə ˈmesɪdʒ ˈsɜːvɪs] 美 [ˈdʒɑvə ˈmesɪdʒ ˈsɜːrvɪs]
释义：消息服务，使用Java消息服务。
语法：JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。
例句：
You have successfully used the JMS protocol for communicating with your SOAP requests.
您已经成功地使用JMS协议和SOAP请求通信了。
扩展资料
JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。
1、StreamMessage -- Java原始值的数据流
2、MapMessage--一套名称-值对
3、TextMessage--一个字符串对象
4、ObjectMessage--一个序列化的 Java对象
5、BytesMessage--一个未解释字节的数据流
什么是JMS消息服务（Java Message Service）?
打个比方。你家里人都在家。那你们聊个天什么的，直接说就可以了。
但是如果你父母在家，你在外地，那要聊个天什么的，吼两句就没办法了。这时候就是要借助电话或者互联网这类工具了。这类工具会把你的消息传达给你的父母，再把你父母的消息传递给你。
而JMS就是这么一个功能。负责多方的消息传输。
一般做分布式，都是把多层应用放到多个服务器上去。比如说，前台服务器接受到用户请求。会先去缓存服务器查一下该页面有没有缓存。那这个时候就要跟缓存服务器通信。发出查询是否有缓存的请求。那你就要建一个这样的服务，让前台可查询。查询后，缓存服务器又要响应结果。
如果没有缓存的话，那这个时候又要与业务层打交道，业务层再与数据层请求。这层与层之间，或者服务器与服务器间通讯，都需要有一套的通讯框架。JSM就是做这个了。
javajms例子的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于jms实现、javajms例子的信息别忘了在本站进行查找喔。
发布于：2022-12-06，除非注明，否则均为原创文章，转载请注明出处。