码迷,mamicode.com
首页 > 其他好文 > 详细

ActiveMQ第一节

时间:2020-02-13 16:44:48      阅读:67      评论:0      收藏:0      [点我收藏+]

标签:throws   设置   end   out   sys   查看   mes   sage   break   

1.消息中间件:采用异步通讯防止,支持点对点以及发布订阅模式,可以解决高并发问题
传统调用接口,可能发生阻塞,重复提交,超时等等问题,可以利用消息中间件发送异步通讯请求

点对点:生产者 消息队列 消费者
发布订阅:生产者 主题 消费者1 消费者N

2.windows安装ActiveMQ
2.1 解压,进入apache-activemq-5.11.1\bin\win64
2.2 启动,双击activeMQ.bat脚本启动,启动窗口不要关闭,可以设置后台启动
2.3 启动完成后,如果发送消息或者消费消息通过61616端口进行 后台查看信息通过8161端口查看
2.4 进入后台登陆:默认用户名和密码都是admin


3.点对点通讯
生产者:

public static void main(String[] args) throws JMSException {
                //步骤一:创建连接工厂
                ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://127.0.0.1:61616");
                //步骤二:创建连接
                Connection connection = activeMQConnectionFactory.createConnection();
                //步骤三:启动连接
                connection.start();
                //步骤四:获取会话工厂
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                //步骤五:创建队列
                Queue queue = session.createQueue("wdksoft_queue");
                //创建消息生产者
                MessageProducer producer = session.createProducer(queue);
                //消息持久化
                producer.setDeliveryMode(2);
                //模拟消息
                TextMessage textMessage = session.createTextMessage("hello activeMQ");
                //发送消息
                producer.send(textMessage);
                System.out.println("生产者生产消息完毕~");
                //回收资源
                session.close();
                connection.close();
            }

消费者:

public static void main(String[] args) throws JMSException {
                //步骤一:创建连接工厂
                ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
                //步骤二:创建连接
                Connection connection = activeMQConnectionFactory.createConnection();
                //步骤三:开启连接
                connection.start();
                //创建会话对象
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                //获取到接受消息的队列
                Queue queue = session.createQueue("wdksoft_queue");
                //创建消费者
                MessageConsumer consumer = session.createConsumer(queue);
                while(true){
                    //获取消息
                    TextMessage message = (TextMessage)consumer.receive();
                    if(message!=null){
                        System.out.println("消费者获取消息:"+message.getText());
                    }else{
                        break;
                    }
                }
                //回收资源
                session.close();
                connection.close();

            }

4.发布订阅模式:消费者先订阅Topic制图,再生产消息
4.1 消费者:

public static void main(String[] args) throws JMSException {
                    //步骤一:创建连接工厂
                    ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
                    //步骤二:创建连接
                    Connection connection = activeMQConnectionFactory.createConnection();
                    //步骤三:开启连接
                    connection.start();
                    //创建会话对象
                    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                    //获取到接受消息的队列
                    Topic topic = session.createTopic("wdksoft_topic");
                    //创建消费者
                    MessageConsumer consumer = session.createConsumer(topic);
                    while(true){
                        //获取消息
                        TextMessage message = (TextMessage)consumer.receive();
                        if(message!=null){
                            System.out.println("消费者获取消息:"+message.getText());
                        }else{
                            break;
                        }
                    }
                    //回收资源
                    session.close();
                    connection.close();
                }

4.2 生产者:

public static void main(String[] args) throws JMSException {
                //步骤一:创建连接工厂
                ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://127.0.0.1:61616");
                //步骤二:创建连接
                Connection connection = activeMQConnectionFactory.createConnection();
                //步骤三:启动连接
                connection.start();
                //步骤四:获取会话工厂
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                //步骤五:创建主题
                Topic topic = session.createTopic("wdksoft_topic");
                //创建消息生产者
                MessageProducer producer = session.createProducer(null);
                //消息持久化
                producer.setDeliveryMode(2);
                //模拟消息
                TextMessage textMessage = session.createTextMessage("hello activeMQ pub");
                //发送消息
                producer.send(topic,textMessage);
                System.out.println("生产者生产消息完毕~");
                //回收资源
                session.close();
                connection.close();
            }

ActiveMQ第一节

标签:throws   设置   end   out   sys   查看   mes   sage   break   

原文地址:https://www.cnblogs.com/ws1149939228/p/12303718.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!