1) jboss配置Queue消息队列
打开jboss安装目录，找到server/default/deploy/jms下找到文件jbossmq-destinations-service.xml文件
增加配置代码如下：
name="jboss.mq.destination:service=Queue,name=testQueue">
启动jboss在jmx-console下，即可查询发布testQueue队列成功的消息，很简单
2）开发发送客户端，拷贝jboss目录下client文件夹下的jbossall-client.jar到项目lib下，编写代码如下
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
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;
public class JmsSender {
public static void main(String[] args) throws JMSException, NamingException {
Properties env = new Properties();
env.put(Context.PROVIDER_URL, "127.0.0.1:1099");
env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
env.put(Context.URL_PKG_PREFIXES,"org.jboss.naming:org.jnp.interfaces");
Context context = new InitialContext(env);
QueueConnectionFactory factory = (QueueConnectionFactory)context.lookup("ConnectionFactory");
QueueConnection queueConnection = factory.createQueueConnection();
QueueSession queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) context.lookup("queue/testQueue");
TextMessage message = queueSession.createTextMessage();
message.setText("ddddd");
QueueSender queueSender = queueSession.createSender(queue);
queueSender.send(queue, message);
System.out.println("-------------");
}
}
开发完毕，很简单
3）接收消息端打开如下
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class JmsReader {
public static void main(String[] args) throws JMSException, NamingException {
Properties env = new Properties();
env.put(Context.PROVIDER_URL, "localhost:1099");
env.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
env.put(Context.URL_PKG_PREFIXES,
"org.jboss.naming:org.jnp.interfaces");
/*
* 利用参数连接好服务器
*/
InitialContext ic = new InitialContext(env);
QueueConnection cs = ((QueueConnectionFactory) ic
.lookup("ConnectionFactory")).createQueueConnection();
/*
* 配置并连接相应的queue
*/
Queue q = (Queue) ic.lookup("queue/testQueue");
QueueSession qss = cs.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
Queu