package com.landingbj.util;

import java.util.Hashtable;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

public class Tool {

public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory";

public final static String PROVIDER_URL=" t3://localhost:7001";

 @SuppressWarnings({ "rawtypes", "unchecked" })

public InitialContext getInitialContext() throws NamingException{

 Hashtable env=new Hashtable();

 env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);

 env.put(Context.PROVIDER_URL, PROVIDER_URL);

     return new InitialContext(env);

 }

}

package com.landingbj.queue;

import javax.jms.*;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import com.landingbj.util.Tool;

public class MessageSender {

 public final static String JMS_FACTORY="JMSConnectionFactory";

 public final static String QUEUE="SevenQueue";

  public static void main(String[] args) throws NamingException, JMSException {

  Tool tool=new Tool();

  InitialContext context =tool.getInitialContext();

  QueueSender sender=null;

  QueueSession session=null;

  QueueConnection connection=null;

try {

//获取连接工厂

QueueConnectionFactory factory=(QueueConnectionFactory)context.lookup(JMS_FACTORY);

 connection=factory.createQueueConnection();

connection.start();

 session=connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

//获取队列

Queue queue = (Queue) context.lookup(QUEUE);

 sender=session.createSender(queue);

TextMessage  message=session.createTextMessage();

message.setText("love milian");

sender.send(message);

System.out.println("send success");

} catch (Exception e) {

e.printStackTrace();

}finally{

sender.close();

session.close();

connection.close();

}

}

}

package com.landingbj.queue;

import javax.jms.*;

import javax.naming.InitialContext;

import com.landingbj.util.Tool;

public class MessageReceive {

public final static String JMS_FACTORY="JMSConnectionFactory";

public final static String QUEUE="SevenQueue";

public static void main(String[] args) {

QueueConnection connection=null;

QueueSession session=null;

try {

 Tool tool=new Tool();

 InitialContext context =tool.getInitialContext();

//获取连接工厂

QueueConnectionFactory factory=(QueueConnectionFactory)context.lookup(JMS_FACTORY);

connection=factory.createQueueConnection();

connection.start();

session=connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

//获取队列

Queue queue=(Queue)context.lookup(QUEUE);

QueueReceiver receive=session.createReceiver(queue);

TextMessage message=(TextMessage)receive.receive();

System.out.println(message.getText());

System.out.println("receive success");

} catch (Exception e) {

e.printStackTrace();

}finally{

try {

session.close();

connection.close();

} catch (JMSException e) {

e.printStackTrace();

}

}

}

}

package com.landingbj.topic;

import javax.jms.*;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import com.landingbj.util.Tool;

public class MessageSender {

public final static String JMS_FACTORY = "JMSConnectionFactory";

public final static String TOPIC = "SevenTopic";

public static void main(String[] args) throws NamingException {

Tool tool = new Tool();

InitialContext context = tool.getInitialContext();

TopicPublisher publisher = null;

TopicSession session = null;

TopicConnection connection = null;

try {

TopicConnectionFactory factory = (TopicConnectionFactory) context

.lookup(JMS_FACTORY);

connection = (TopicConnection) factory.createTopicConnection();

connection.start();

session = connection.createTopicSession(false,

Session.AUTO_ACKNOWLEDGE);

Topic topic = (Topic) context.lookup(TOPIC);

publisher = session.createPublisher(topic);

TextMessage message = session.createTextMessage();

message.setText("Topic测试连接");

publisher.publish(message);

System.out.println("Topic消息已发送！");

} catch (JMSException e) {

e.printStackTrace();

} finally {

try {

session.close();

connection.close();

} catch (Exception e) {

e.printStackTrace();

}

}

}

}

package com.landingbj.topic;

import javax.jms.*;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import com.landingbj.util.Tool;

public class MessageReceiver {

public final static String JMS_FACTORY = "JMSConnectionFactory";

public final static String TOPIC = "SevenTopic";

public static void main(String[] args) throws NamingException {

Tool tool = new Tool();

InitialContext context = tool.getInitialContext();

TopicSession session = null;

TopicConnection connection = null;

try {

TopicConnectionFactory factory = (TopicConnectionFactory) context

.lookup(JMS_FACTORY);

connection=(TopicConnection) factory.createTopicConnection();

connection.start();

session = connection.createTopicSession(false,

Session.AUTO_ACKNOWLEDGE);

Topic topic = (Topic) context.lookup(TOPIC);

TopicSubscriber subscriber=session.createSubscriber(topic);

TextMessage message=(TextMessage) subscriber.receive();

System.out.println(message.getText());

subscriber.setMessageListener(new MessageListener() {

public void onMessage(Message msg) {

try {

System.out.println(((TextMessage)msg).getText());

} catch (JMSException e) {

e.printStackTrace();

}

}

});

} catch (JMSException e) {

e.printStackTrace();

}finally{

try {

session.close();

connection.close();

} catch (JMSException e) {

e.printStackTrace();

}

}

}

}