RabbitMQ安装、配置与入门

喜欢ヅ旅行 2022-01-17 03:41 252阅读 0赞

## 1、下载与安装 ##

### 1.1 Erlang下载安装 ###

由于RabbitMQ使用Erlang语言编写，所以先安装Erlang语言运行环境。  
[http://www.erlang.org/downloads][http_www.erlang.org_downloads]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]  
下载后，直接单击Next下一步进行安装

然后配置环境变量  
![在这里插入图片描述][20190612185030714.png]

ERLANG_HOME=C:\Program Files\erl10.4

在Path中增加

%ERLANG_HOME%\bin

### 1.2 RabbitMQ下载安装 ###

[https://www.rabbitmq.com/install-windows.html][https_www.rabbitmq.com_install-windows.html]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 1]  
安装完成后，进行环境变量配置  
![在这里插入图片描述][20190612185549701.png]

RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.15

继续在Path中增加

%RABBITMQ_SERVER%\sbin;

## 2、基本配置 ##

### 2.1 开机启动 ###

Microsoft Windows [版本 6.1.7601]
    版权所有 (c) 2009 Microsoft Corporation。保留所有权利。
    
    D:\Users\chengyq>rabbitmq-service enable
    C:\Program Files\erl10.4\erts-10.4\bin\erlsrv: Service RabbitMQ enabled.

### 2.2 启动服务 ###

D:\Users\chengyq>rabbitmq-service start
    请求的服务已经启动。
    
    请键入 NET HELPMSG 2182 以获得更多的帮助。

### 2.3 查询状态 ###

D:\Users\chengyq>rabbitmqctl status
    Status of node rabbit@TPA-VDI-OA02-10 ...
    [{pid,9344},
     {running_applications,
         [{rabbit,"RabbitMQ","3.7.15"},
          {mnesia,"MNESIA  CXC 138 12","4.16"},
          {rabbit_common,
              "Modules shared by rabbitmq-server and rabbitmq-erlang-client",
              "3.7.15"},
          {ranch,"Socket acceptor pool for TCP protocols.","1.7.1"},
          {ssl,"Erlang/OTP SSL application","9.3"},
          {public_key,"Public key infrastructure","1.6.7"},
          {asn1,"The Erlang ASN1 compiler version 5.0.9","5.0.9"},
          {inets,"INETS  CXC 138 49","7.0.8"},
          {jsx,"a streaming, evented json parsing toolkit","2.9.0"},
          {crypto,"CRYPTO","4.5"},
          {sysmon_handler,"Rate-limiting system_monitor event handler","1.1.0"},
          {os_mon,"CPO  CXC 138 46","2.5"},
          {observer_cli,"Visualize Erlang Nodes On The Command Line","1.5.0"},
          {xmerl,"XML parser","1.3.21"},
          {recon,"Diagnostic tools for production use","2.5.0"},
          {lager,"Erlang logging framework","3.6.10"},
          {goldrush,"Erlang event stream processor","0.1.9"},
          {compiler,"ERTS  CXC 138 10","7.4"},
          {syntax_tools,"Syntax tools","2.2"},
          {sasl,"SASL  CXC 138 11","3.4"},
          {stdlib,"ERTS  CXC 138 10","3.9"},
          {kernel,"ERTS  CXC 138 10","6.4"}]},
     {os,{win32,nt}},
     {erlang_version,
         "Erlang/OTP 22 [erts-10.4] [64-bit] [smp:4:4] [ds:4:4:10] [async-threads:64
    ]\n"},
     {memory,
         [{connection_readers,0},
          {connection_writers,0},
          {connection_channels,0},
          {connection_other,0},
          {queue_procs,0},
          {queue_slave_procs,0},
          {plugins,16740},
          {other_proc,23525912},
          {metrics,196492},
          {mgmt_db,0},
          {mnesia,77816},
          {other_ets,2525544},
          {binary,199520},
          {msg_index,32208},
          {code,24245647},
          {atom,1131721},
          {other_system,11012656},
          {allocated_unused,11156960},
          {reserved_unallocated,0},
          {strategy,rss},
          {total,[{erlang,62964256},{rss,74121216},{allocated,74121216}]}]},
     {alarms,[]},
     {listeners,[{clustering,25672,"::"},{amqp,5672,"::"},{amqp,5672,"0.0.0.0"}]},
     {vm_memory_calculation_strategy,rss},
     {vm_memory_high_watermark,0.4},
     {vm_memory_limit,3435787059},
     {disk_free_limit,50000000},
     {disk_free,175843475456},
     {file_descriptors,
         [{total_limit,8092},
          {total_used,2},
          {sockets_limit,7280},
          {sockets_used,0}]},
     {processes,[{limit,1048576},{used,243}]},
     {run_queue,1},
     {uptime,872},
     {kernel,{net_ticktime,60}}]

### 2.4 查看用户 ###

D:\Users\chengyq>rabbitmqctl list_users
    Listing users ...
    user    tags
    guest   [administrator]

### 2.5 开启rabbitmq\_management ###

开启rabbitmq\_management插件，在web界面查看和管理RabbitMQ服务

D:\Users\chengyq>rabbitmq-plugins enable rabbitmq_management
    Enabling plugins on node rabbit@TPA-VDI-OA02-10:
    rabbitmq_management
    The following plugins have been configured:
      rabbitmq_management
      rabbitmq_management_agent
      rabbitmq_web_dispatch
    Applying plugin configuration to rabbit@TPA-VDI-OA02-10...
    The following plugins have been enabled:
      rabbitmq_management
      rabbitmq_management_agent
      rabbitmq_web_dispatch
    
    started 3 plugins.
    
    D:\Users\chengyq>

地址 [http://localhost:15672/][http_localhost_15672]  
默认的用户名：guest  
默认的密码为：guest  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 2]

## 3、简单样例程序 ##

### 3.1 依赖 ###

<dependency>
                <groupId>com.rabbitmq</groupId>
                <artifactId>amqp-client</artifactId>
                <version>5.7.1</version>
            </dependency>

### 3.2 公共类 ###

import com.rabbitmq.client.AMQP;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class Util {
        public static Connection getConnection() {
            // connection是socket连接的抽象，并且为我们管理协议版本协商（protocol version negotiation），
            // 认证（authentication ）等等事情。这里我们要连接的消息代理在本地，因此我们将host设为“localhost”。
            // 如果我们想连接其他机器上的代理，只需要将这里改为特定的主机名或IP地址。
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(5672); //默认端口号
            factory.setUsername("guest");//默认用户名
            factory.setPassword("guest");//默认密码
            try {
                return factory.newConnection();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (TimeoutException e) {
                e.printStackTrace();
            }
            return null;
        }
    }

### 3.3 消息发送者 ###

import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    
    public class Send {
        private final static String QUEUE_NAME = "Hello";
    
        public static void main(String[] args) throws Exception {
            Connection connection = Util.getConnection();
            Channel channel = connection.createChannel();
            // 接下来，我们创建一个channel，绝大部分API方法需要通过调用它来完成。
            // 发送之前，我们必须声明消息要发往哪个队列，然后我们可以向队列发一条消息：
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "[x] Hello world";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println("Sent '" + message + "'");
            channel.close();
            connection.close();
        }
    }

![在这里插入图片描述][20190612194500888.png]

### 3.3 消息接受者 ###

import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    public class Receiver {
        private final static String QUEUE_NAME = "Hello";
    
        public static void main(String[] args) throws Exception {
            Connection connection = Util.getConnection();
            Channel channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
            Consumer consumer = new DefaultConsumer(channel) {
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                                           byte[] body) throws IOException {
                    String message = new String(body, "UTF-8");
                    System.out.println(" [x] Received '" + message + "'");
                }
            };
            channel.basicConsume(QUEUE_NAME, true, consumer);
        }
    }

![在这里插入图片描述][20190612194521804.png]

[http_www.erlang.org_downloads]: http://www.erlang.org/downloads
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]: /images/20220117/18016b4e7faf4a40adab6d31718fa280.png
[20190612185030714.png]: /images/20220117/24db4d0a4c63402e926a34e2f062e22d.png
[https_www.rabbitmq.com_install-windows.html]: https://www.rabbitmq.com/install-windows.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 1]: /images/20220117/c6e9719bea3e4dc5bdd8d4709760b4b5.png
[20190612185549701.png]: /images/20220117/7d0f64dc0789406cbf95159e156ea53e.png
[http_localhost_15672]: http://localhost:15672/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 2]: /images/20220117/aa5350f4fbb343aea1703e2e6199f13a.png
[20190612194500888.png]: /images/20220117/0037d519151e4c0ca921e338338e1d10.png
[20190612194521804.png]: /images/20220117/07dd998af20a41988c41bde4dd10e779.png