ActiveMQ之JMS

╰+攻爆jí腚メ 2021-09-28 10:20 402阅读 0赞

下面分享一下，最近写的JMS的示例

1、通过黑窗口切换到activemq的bin目录下，运行activemq start命令启动activemq；  
2.、发送端

package com.wxy.sender;
    
    import javax.jms.*;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    /**
     * @Description: 消息发送者
     * @author wxy 
     * @date 2019年4月4日 下午3:37:29
     */
    public class Sender {
    	//消息服务器的连接地址
    	public static final String BROKER_URL = "tcp://192.168.17.193:61616";
    	
    	public static void main(String[] args) {
    		Sender sender = new Sender();
    		sender.sendMessage("hello wxy");
    	}
    	
    	//发送消息
    	public void sendMessage(String msg) {
    		Connection connection = null;
    		Session session = null;
    		MessageProducer messageProducer = null;
    		
    		try {
    			//1、创建一个连接工厂
    			ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
    			//2、创建一个连接
    			connection = connectionFactory.createConnection();
    			//3、创建一个Session
    			session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    			//4、创建消息，此处创建了一个文本消息
    			Message message = session.createTextMessage(msg);
    			//5、创建一个目的地
    			Destination destination = session.createQueue("wxyQueue");
    			//6、创建一个消息的生产者（发送者）
    			messageProducer = session.createProducer(destination);
    			//7、发送消息
    			messageProducer.send(message);
    			
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				//关闭连接释放资源
    				if(null != messageProducer) {
    					messageProducer.close();
    				}
    				if(null != session) {
    					session.close();
    				}
    				if(null != connection) {
    					connection.close();
    				}
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    	}
    }

3、接收端

package com.wxy.receiver;
    
    import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.Destination;
    import javax.jms.Message;
    import javax.jms.MessageConsumer;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    public class Receiver {
    	//消息服务器的连接地址
    	public static final String BROKER_URL = "tcp://192.168.17.193:61616";
    	
    	public static void main(String[] args) {
    		Receiver receiver = new Receiver();
    		receiver.receiveMessage();
    	}
    	
    	//接收消息
    	public void receiveMessage() {
    		Connection connection = null;
    		Session session = null;
    		MessageConsumer messageConsumer = null;
    		try {
    			//1、创建一个连接工厂
    			ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
    			//2、创建一个连接
    			connection = connectionFactory.createConnection();
    			//3、创建一个session
    			session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    			//4、创建一个目的地
    			Destination destination = session.createQueue("wxyQueue");
    			//5、创建一个消息的消费者（接收者）
    			messageConsumer = session.createConsumer(destination);
    			//接收消息之前，需要把连接启动下
    			connection.start();
    			//6、接收消息
    			Message message = messageConsumer.receive();
    			//判断消息的类型
    			if(message instanceof TextMessage){//判断是否是文本消息
    				String text = ((TextMessage)message).getText();
    				System.out.println("接收到的消息内容为：" + text);
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				if(null != messageConsumer) {
    					messageConsumer.close();
    				}
    				if(null != session) {
    					session.close();
    				}
    				if(null != connection) {
    					connection.close();
    				}
    			} catch (Exception e2) {
    				e2.printStackTrace();
    			}
    		}
    	}
    }