您的位置: 首页  >  文章  >  Windows下安装RabbitMQ

Windows下安装RabbitMQ

分类: 文章 • 2024-05-10 19:13:52
本文转载自:https://blog.****.net/hzw19920329/article/details/53156015

1.Windows下安装的RabbitMQ需要以下几个步骤

   （1）：下载erlang，原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，下载地址：http：//www.erlang.org/downloads，双击.exe文件进行安装就好，安装完成之后创建一个名为ERLANG_HOME的环境变量，其值指向二郎的安装目录，同时将％ERLANG_HOME％\ bin中加入到路径中，最后打开命令行，输入ERL，如果出现二郎的版本信息就表示Erlang的语言环境安装成功;

Windows下安装RabbitMQ                      

 Windows下安装RabbitMQ

   （2）：下载RabbitMQ，下载地址：http：//www.rabbitmq.com/，同样双击.exe进行安装就好（这需要注意一点，默认的安装目录是C：/ Program Files / .... ，这个目录中是存在空格符的，我们需要改变安装目录，貌似RabbitMQ的安装目录中是不允许有空格的，我之前踩过这个大坑）;

   （3）：安装RabbitMQ-Plugins，这个相当于是一个管理界面，方便我们在浏览器界面查看RabbitMQ各个消息队列以及交换的工作情况，安装方法是：打开命令行cd进入rabbitmq的sbin目录（我的目录是：E：\ software \ rabbitmq \ rabbitmq_server-3.6.5 \ sbin），输入：rabbitmq-plugins enable rabbitmq_management命令，稍等会会发现出现plugins安装成功的提示，默认是安装6个插件，如果你在安装插件的过程中出现了下面的错误：        

Windows下安装RabbitMQ

   解决方法是：首先在命令行输入：rabbitmq-service stop，接着输入rabbitmq-service remove，再接着输入rabbitmq-service install，接着输入rabbitmq-service start，最后重新输入rabbitmq-plugins enable rabbitmq_management试试，我是这样解决的;

   （4）：插件安装完之后，在浏览器输入的http：//本地主机：15672进行验证，你会看到下面界面，输入用户名：客人，密码：客人你就可以进入管理界面，当然用户名密码你都可以变的;

Windows下安装RabbitMQ

2.安装完的RabbitMQ之后，我们先来简单了解下的RabbitMQ中涉及到的几个概念

    制片人：消息生产者

    消费者：消息消费者

     虚拟主机：虚拟主机，在RabbitMQ中，用户只能在虚拟主机的层面上进行一些权限设置，比如我可以访问哪些队列，我可以处理哪些请求等等;

     经纪人：消息转发者，也就是我们的RabbitMQ服务端充当的功能了，那么消息是按照什么规则进行转发的呢需要用到下面几个概念;

     exchange：交换机，他是和producer直接进行打交道的，有点类似于路由器的功能，主要就是进行转发操作的呗，那么producer到底用哪个交换进行路由呢？这个取决于路由键（路由键），每个消息都有这个键，我们也可以自己设定，其实就是一字符串;

     队列：消息队列，用于存放消息，他接收交换路由过来的消息，我们可以对队列内容进行持久化操作，那么队列到底接收那个交换路由的消息呢？这个时候就要用到binding key键）了，绑定键会将队列和交换进行绑定，至于绑定方式，RabbitMQ的提供了多种方式，大家可以看看鸿洋大神的RabbitMQ的博客系列（点击查看）;

     以上就是RabbitMQ的涉及到的一些概念了，用一张图表示这些概念之间的关系就是：

Windows下安装RabbitMQ

3.RabbitMQ简单使用

   生产者（生产者）端步骤：

    （1）：创建的ConnectionFactory，并且设置一些参数，比如主机名，端口号等等

    （2）：利用连接工厂创建一个连接连接

    （3）：利用连接创建一个频道通道

    （4）：创建队列并且和信道进行绑定

    （5）：创建消息，并且发送到队列中

     注意，在我们当前的例子中，并没有用到交换交换机，RabbitMQ的默认情况下是会创建一个空字符串名字的交换的，如果我们没有创建自己的交换的话，默认就是使用的这个交换;

     生产端代码：

[java] 查看纯文本 
  1. 公共类 发件人{   
  2.     私人最终静态 字符串QUEUE_NAME =  “MyQueue” ;    
  3.       
  4.     public static void  main（String [] args）{    
  5.         发送（）;  
  6.     }  
  7.       
  8.     public static void  send（）    
  9.     {  
  10.         ConnectionFactory factory =  null ;  
  11.         连接连接=  空;  
  12.         频道频道=  空;  
  13.         尝试 {  
  14.             factory =  new  ConnectionFactory（）;  
  15.             factory.setHost（“localhost” ）;  
  16.             connection = factory.newConnection（）;  
  17.             channel = connection.createChannel（）;  
  18.             channel.queueDeclare（QUEUE_NAME，  false ，  false ，  false ，  null ）;  
  19.             String message =  “我的第一条消息.....” ;  
  20.             channel.basicPublish（“” ，QUEUE_NAME，  null ，message.getBytes（“UTF-8” ））;  
  21.             System.out.println（“已经发送消息.....” +消息）;  
  22.         }  catch  （IOException e）{  
  23.             e.printStackTrace（）;  
  24.         }  catch  （TimeoutException e）{  
  25.             e.printStackTrace（）;  
  26.         } finally {  
  27.             尝试 {  
  28.                 //关闭资源  
  29.                 channel.close（）;  
  30.                 connection.close（）时;  
  31.             }  catch  （IOException e）{  
  32.                 e.printStackTrace（）;  
  33.             }  catch  （TimeoutException e）{  
  34.                 e.printStackTrace（）;  
  35.             }  
  36.         }  
  37.     }  
  38. }  

     消费者（消费者）端步骤：

     （1）：创建的ConnectionFactory，并且设置一些参数，比如主机名，端口号等等

     （2）：利用连接工厂创建一个连接连接

     （3）：利用连接创建一个频道通道

     （4）：将队列和信道进行绑定，注意这里的队列名字要和前面生产者创建的队列一致

     （5）：创建消费者消费来接收消息，同时将消费者和队列进行绑定

     消费端代码：

[java] 查看纯文本 
  1. 公共类 Receiver {   
  2.     私人最终静态 字符串QUEUE_NAME =  “MyQueue” ;    
  3.       
  4.     public static void  main（String [] args）{    
  5.         接收（）;  
  6.     }  
  7.       
  8.     public static void  receive（）    
  9.     {  
  10.         ConnectionFactory factory =  null ;  
  11.         连接连接=  空;  
  12.         频道频道=  空;  
  13.           
  14.         尝试 {  
  15.             factory =  new  ConnectionFactory（）;  
  16.             factory.setHost（“localhost” ）;  
  17.             connection = factory.newConnection（）;  
  18.             channel = connection.createChannel（）;  
  19.             channel.queueDeclare（QUEUE_NAME，  false ，  false ，  false ，  null ）;  
  20.             消费者消费者=  新的 DefaultConsumer（频道）{  
  21.                 @覆盖  
  22.                 public void  handleDelivery（String consumerTag，Envelope envelope，BasicProperties properties，   
  23.                         byte [] body）  throws  IOException {  
  24.                     System.out.println（“11111111111” ）;  
  25.                     String message =  new  String（body，  “UTF-8” ）;  
  26.                     System.out.println（“收到消息.....” +消息）;  
  27.                 }};  
  28.             channel.basicConsume（QUEUE_NAME，  true ，consumer）;  
  29.         }  catch  （IOException e）{  
  30.             e.printStackTrace（）;  
  31.         }  catch  （TimeoutException e）{  
  32.             e.printStackTrace（）;  
  33.         } finally {  
  34.             尝试 {  
  35.                 //关闭资源  
  36.                 channel.close（）;  
  37.                 connection.close（）时;  
  38.             }  catch  （IOException e）{  
  39.                 e.printStackTrace（）;  
  40.             }  catch  （TimeoutException e）{  
  41.                 e.printStackTrace（）;  
  42.             }  
  43.         }  
  44.     }  
  45. }  

相关推荐