前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >快速学习-RabbitMQ快速入门

快速学习-RabbitMQ快速入门

作者头像
cwl_java
发布2020-01-14 14:49:19
1.1K0
发布2020-01-14 14:49:19
举报
文章被收录于专栏:cwl_Java

2 快速入门

2.1 RabbitMQ的工作原理

下图是RabbitMQ的基本结构:

在这里插入图片描述
在这里插入图片描述

组成部分说明如下:

  • Broker:消息队列服务进程,此进程包括两个部分:Exchange和Queue。
  • Exchange:消息队列交换机,按一定的规则将消息路由转发到某个队列,对消息进行过虑。
  • Queue:消息队列,存储消息的队列,消息到达队列并转发给指定的消费方。
  • Producer:消息生产者,即生产方客户端,生产方客户端将消息发送到MQ。
  • Consumer:消息消费者,即消费方客户端,接收MQ转发的消息。

消息发布接收流程:

-----发送消息-----

  1. 生产者和Broker建立TCP连接。
  2. 生产者和Broker建立通道。
  3. 生产者通过通道消息发送给Broker,由Exchange将消息进行转发。
  4. Exchange将消息转发到指定的Queue(队列)

----接收消息-----

  1. 消费者和Broker建立TCP连接
  2. 消费者和Broker建立通道
  3. 消费者监听指定的Queue(队列)
  4. 当有消息到达Queue时Broker默认将消息推送给消费者。
  5. 消费者接收到消息。

2.2 下载安装

2.2.1 下载安装

RabbitMQ由Erlang语言开发,Erlang语言用于并发及分布式系统的开发,在电信领域应用广泛,OTP(Open Telecom Platform)作为Erlang语言的一部分,包含了很多基于Erlang开发的中间件及工具库,安装RabbitMQ需 要安装Erlang/OTP,并保持版本匹配,如下图:

RabbitMQ的下载地址:http://www.rabbitmq.com/download.html

在这里插入图片描述
在这里插入图片描述

1)下载erlang 地址如下: http://erlang.org/download/otp_win64_20.3.exe

erlang安装完成需要配置erlang环境变量: ERLANG_HOME=D:\Program Files\erl9.3 在path中添加%ERLANG_HOME%\bin;

2)安装RabbitMQ https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.7.3

2.2.2 启动

安装成功后会自动创建RabbitMQ服务并且启动。

1)从开始菜单启动RabbitMQ 完成在开始菜单找到RabbitMQ的菜单:

在这里插入图片描述
在这里插入图片描述
  • RabbitMQ Service-install :安装服务
  • RabbitMQ Service-remove 删除服务
  • RabbitMQ Service-start 启动
  • RabbitMQ Service-stop 停止

2)如果没有开始菜单则进入安装目录下sbin目录手动启动:

在这里插入图片描述
在这里插入图片描述

1)安装并运行服务

  • rabbitmq-service.bat install 安装服务
  • rabbitmq-service.bat stop 停止服务
  • rabbitmq-service.bat start 启动服务

2)安装管理插件 安装rabbitMQ的管理插件,方便在浏览器端管理RabbitMQ 管理员身份运行 rabbitmq-plugins.bat enable rabbitmq_management

3、启动成功 登录RabbitMQ 进入浏览器,输入:http://localhost:15672

在这里插入图片描述
在这里插入图片描述

初始账号和密码:guest/guest

在这里插入图片描述
在这里插入图片描述

2.2.3 注意事项

  1. 安装erlang和rabbitMQ以管理员身份运行。
  2. 当卸载重新安装时会出现RabbitMQ服务注册失败,此时需要进入注册表清理erlang 搜索RabbitMQ、ErlSrv,将对应的项全部删除。

2.3 Hello World

按照官方教程(http://www.rabbitmq.com/getstarted.html)测试hello world:

在这里插入图片描述
在这里插入图片描述

2.3.1搭建环境

1)java client 生产者和消费者都属于客户端,rabbitMQ的java客户端如下:

在这里插入图片描述
在这里插入图片描述

我们先用 rabbitMQ官方提供的java client测试,目的是对RabbitMQ的交互过程有个清晰的认识。 参考 :https://github.com/rabbitmq/rabbitmq-java-client/

2)创建maven工程 创建生产者工程和消费者工程,分别加入RabbitMQ java client的依赖。 test-rabbitmq-producer:生产者工程 test-rabbitmq-consumer:消费者工程

代码语言:javascript
复制
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp‐client</artifactId>
            <version>4.0.3</version>
            <!‐‐此版本与spring boot 1.5.9版本匹配‐‐>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring‐boot‐starter‐logging</artifactId>
        </dependency>

2.3.2 生产者

代码语言:javascript
复制
public class Producer01 {
    //队列名称
    private static final String QUEUE = "helloworld";

    public static void main(String[] args) throws IOException, TimeoutException {
        Connection connection = null;
        Channel channel = null;
        try {
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(5672);
            factory.setUsername("guest");
            factory.setPassword("guest");
            factory.setVirtualHost("/");
            //rabbitmq默认虚拟机名称为“/”,虚拟机相当于一个独立的mq服务 器
            // 创建与RabbitMQ服务的TCP连接
            connection = factory.newConnection();
            //创建与Exchange的通道,每个连接可以创建多个通道,每个通道代表一个会话任务
            channel = connection.createChannel(); /*** 声明队列,如果Rabbit中没有此队列将自动创建 * param1:队列名称 * param2:是否持久化 * param3:队列是否独占此连接 * param4:队列不再使用时是否自动删除此队列 * param5:队列参数 */
            channel.queueDeclare(QUEUE, true, false, false, null);
            String message = "helloworld小明" + System.currentTimeMillis();
            /*** 消息发布方法 * param1:Exchange的名称,如果没有指定,则使用Default Exchange * param2:routingKey,消息的路由Key,是用于Exchange(交换机)将消息转发到指定的消息队列 * param3:消息包含的属性 * param4:消息体 */
            /*** 这里没有指定交换机,消息将发送给默认交换机,每个队列也会绑定那个默认的交换机,但是不能显 示绑定或解除绑定* 默认的交换机,routingKey等于队列名称 */
            channel.basicPublish("", QUEUE, null, message.getBytes());
            System.out.println("Send Message is:'" + message + "'");
        } catch (Exception ex) {
            ex.printStackTrace();
        } finally {
            if (channel != null) {
                channel.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
    }
}

2.3.3 消费者

代码语言:javascript
复制
public class Consumer01 {
    private static final String QUEUE = "helloworld";

    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        //设置MabbitMQ所在服务器的ip和端口
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        //声明队列
        channel.queueDeclare(QUEUE, true, false, false, null);
        //定义消费方法
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /*** 消费者接收消息调用此方法
             * @param consumerTag 消费者的标签,在channel.basicConsume()去指定
             * @param envelope 消息包的内容,可从中获取消息id,消息routingkey,交换机,消息和重传标志 (收到消息失败后是否需要重新发送)
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                //交换机 
                String exchange = envelope.getExchange();
                //路由key 
                String routingKey = envelope.getRoutingKey();
                //消息id 
                long deliveryTag = envelope.getDeliveryTag();
                //消息内容 
                String msg = new String(body, "utf‐8");
                System.out.println("receive message.." + msg);
            }
        };/*** 监听队列String queue, boolean autoAck,Consumer callback * 参数明细 * 1、队列名称 * 2、是否自动回复,设置为true为表示消息接收到自动向mq回复接收到了,mq接收到回复会删除消息,设置 为false则需要手动回复 * 3、消费消息的方法,消费者接收到消息后调用此方法 */
        channel.basicConsume(QUEUE, true, consumer);
    }
}

2.3.4 总结

1、发送端操作流程 1)创建连接 2)创建通道 3)声明队列 4)发送消息

2、接收端 1)创建连接 2)创建通道 3)声明队列 4)监听队列 5)接收消息 6)ack回复

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 2 快速入门
    • 2.1 RabbitMQ的工作原理
      • 2.2 下载安装
        • 2.2.1 下载安装
        • 2.2.2 启动
        • 2.2.3 注意事项
      • 2.3 Hello World
        • 2.3.1搭建环境
        • 2.3.2 生产者
        • 2.3.3 消费者
        • 2.3.4 总结
    相关产品与服务
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档