RabbitMQ的安装以及使用(Windows环境)

一、RabbitMQ介绍

1、RabbitMQ简介

RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

2、RabbitMQ简介(白话)

上述简介摘自百度百科,相关术语自行百度吧。。。反正我也看不懂,太深奥。
做个比喻:
快递员A需要将一个快递给客户B。
原本:A亲手将快递交给B。
问题:B现在有很多事要做,A只能等着B处理完事情,才能把快递交给他,A就很难受了,送不了几个快递,没法赚钱了。
解决:设置一个快递柜,A把快递放进快递柜,就可以送下一个快递了,B啥时候有空了,去快递柜拿就行了。
总结:快递就是消息,快递柜就是消息队列。快递柜有很多种,菜鸟,丰巢等,RabbitMQ就是其中一种快递柜
放在程序里举例:
客户提交订单,支付系统——>订单系统,支付系统可能很快就执行完了,但是订单系统要很久才能执行完,每次支付系统都要等待订单系统,服务端速度就会很慢,现在使用RabbitMQ,支付系统支付成功后,发送一个支付成功消息到RabbitMQ,就可以返回前端了,订单系统在获取到消息后,慢慢再执行订单修改的程序。(当然,要考虑到某个系统出了异常怎么办,这个入门先不管,只管正常情况。)

二、RabbitMQ的安装

1、Erlang的安装

因为RabbitMQ是用Erlang语言编写的,所以要安装RabbitMQ先要安装Erlang。
下载地址: http://www.erlang.org/downloads
根据需要选择版本
选择 Windows 64-bit版,下载完成后直接安装,一直NEXT。(路径自行选择)(官网下载速度会比较慢)

2、RabbitMQ安装程序

注意:请确认计算机名为英文,中文可能会导致RabbitMQ启动失败。如果启动失败,请改成英文后,卸载并重新安装

下载地址: http://www.rabbitmq.com/install-windows.html
根据需要选择版本(注意:RabbitMQ和Erlang版本可能存在不匹配情况)
选择Bintray版本,下载完成后直接安装,一直NEXT。(路径自行选择)

3、自定义环境变量

(1)erl环境变量配置

ERLANG_HOME=D:\Program\erl9.2

在Path中加入

%ERLANG_HOME%\bin;

(2)RabbitMQ环境变量配置

这里注意,看好你RabbitMQ的安装位置,以及安装的版本,我的版本为3.7.3

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

在Path中加入

%RABBITMQ_SERVER%\sbin;

4、激活rabbitmq_management

在CMD中进入以下目录,键入如下命令,不出错即可

rabbitmq-plugins.bat enable rabbitmq_management

5、启动RabbitMQ服务

需要以管理员方式启动CMD

在命令行界面键入如下命令

net start RabbitMQ

因为RabbitMQ默认启动的,当键入启动命令时,会出现如下情况,直接关闭RabbitMQ服务,再启动就行。

关闭RabbitMQ服务命令如下:

net stop RabbitMQ

三、RabbitMQ测试

测试地址 http://localhost:15672/
默认的用户名:guest
默认的密码为:guest

四、Java客户端测试(maven)

1、maven项目中添加RabbitMQ依赖

直接在项目的pom.xml文件中添加如下依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

2、新建SendMQ类,发送端

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;

public class SendMQ {
    private final static String QUEUE_NAME = "Hello";

    public static void main(String[] args) throws IOException, Exception {
        // 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");//默认密码
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        // 接下来,我们创建一个channel,绝大部分API方法需要通过调用它来完成。
        // 发送之前,我们必须声明消息要发往哪个队列,然后我们可以向队列发一条消息:
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String message = "Hello world";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
        System.out.println(" [x] Sent ‘" + message + "‘");
        channel.close();
        connection.close();
    }
}

3、新建RecvMQ类,接收端

import com.rabbitmq.client.*;

import java.io.IOException;

public class RecvMQ {
    private final static String QUEUE_NAME = "Hello";

    public static void main(String[] args) throws IOException, Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");
        Connection connection = factory.newConnection();
        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);
    }
}

4、运行两个类测试

原文地址:https://www.cnblogs.com/qingmuchuanqi48/p/12306308.html

时间: 2024-10-07 21:10:04

RabbitMQ的安装以及使用(Windows环境)的相关文章

Jmeter - 在Linux环境安装Jmeter - 在Windows环境安装Jmeter

当配置完Jmeter运行的环境之后,就可以开始安装Jmeter了. 为什么既要告诉各位"在Linux系统内安装Jmeter",又要告诉各位"在Windows系统内安装Jmeter"?因为当我们在构建1个测试计划的步骤是: (1)首先,Windows的Jmeter图形化窗口内,构建1个测试计划 (2)然后,把构建好的这个测试计划上传到Linux系统的测试机 (3)最后,在Linux系统的测试机,用Jmeter做性能测试 也就是说,我们在Windows.Linux的电脑上,都会用到Jmeter. 那

tensorflow安装过程-(windows环境下)---详解

一, 前言:本次安装tensorflow是基于Python的,安装Python的过程不做说明(既然决定按,Python肯定要先了解啊):本次教程是windows下Anaconda安装Tensorflow的过程(cpu版,显卡不支持gpu版的...) 二, 安装环境:(tensorflow支持的系统是64位的,windows和linux,mac都需要64位) windows7(其实和windows版本没什么关系,我的是windows7,安装时参照的有windows10的讲解) Python3.5.

zookeeper安装和使用 windows环境

简介 ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件.它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护.域名服务.分布式同步.组服务等. ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效.功能稳定的系统提供给用户. ZooKeeper包含一个简单的原语集,提供Java和C的接口. ZooKeeper代码版本中,提供了分布式独享锁.选举.队列的接

Windows环境安装MySQL8.0.11

网络开发数据库是必不可少的.曾经安装个Mysql,但是忘了.再次安装还是得百度.那还不如自己写篇博客记录一下呢,以后再忘记就看自己的博客好 Mysql官网安装地址(windows环境): https://dev.mysql.com/downloads/installer/   (不知道博客园会不会和谐外部链接). 软件包只有32位的,但是根据页面上说明,安装的时候 32,64都可以安. 双击安装包,等待一会儿 .勾选后,next. 仅安装服务端 原文地址:https://www.cnblogs.

RabbitMQ的安装与客户端的简单实用

本文主要内容是RabbitMQ的安装步骤[Windows系统与linux上的安装]及客户端的简单使用. 1.下载 下载地址:http://www.rabbitmq.com/download.html 2.Windows上安装 2.1 安装安装Erlang 下载erlang:http://www.erlang.org/download/otp_win64_17.3.exe 安装: erlang安装完成. 2.2 安装安装RabbitMQ RabbitMQ安装完成. 启动.停止.重新安装等. 2.3

RabbitMQ在windows环境下的安装

最近一直想入手一台电脑,作为linux服务器,由于经济状况也没有入手,现在就先介绍windows环境下安装rabbitMQ. RabbitMQ是什么 ? RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统.他遵循Mozilla Public License开源协议. 1.RabbitMQ 它依赖于Erlang,需要先安装Erlang.首先确定你的window电脑是32位还是64位,以下的安装以window 64位电脑举例. 安装RabbitMQ需要先安装Erlang语言开发包.下

Linux &amp; Windows 环境下 RabbitMQ 安装与基本配置

索引: 开源Spring解决方案--lm.solution 参看代码 GitHub: rabbitmq.txt 一.Linux (DeepinOS) 环境 1 1.安装: 2 sudo apt install rabbitmq-server 3 2.进入目录 -- /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.10/sbin: 4 输入命令启动: 5 sudo rabbitmq-server 6 3.安装以后可以通过下面的命令,停止: 7 sudo rabb

windows环境安装RabbitMQ

第一步:下载并安装erlang 原因:RabbitMQ服务端代码是使用并发式语言Erlang编写的,安装Rabbit MQ的前提是安装Erlang. 下载地址:http://www.erlang.org/downloads 配置环境变量 变量名:ERLANG_HOME 变量值就是刚才erlang的安装地址,点击确定. 然后双击系统变量path 点击“新建”,将%ERLANG_HOME%\bin加入到path中. 最后windows键+R键,输入cmd,再输入erl,看到版本号就说明erlang安

RabbitMQ 在Windows环境下安装

1. 下载RabbitMQ和Erlang RabbitMQ下载地址  https://www.rabbitmq.com/install-windows.html RabbitMQ是用Erlang编程语言进行开发,所以先要安装Erlang语言开发包.Erlang官网下载地址:https://www.erlang.org/downloads 2. 安装,配置Erlang环境变量 以管理员身份运行,然后一直next即可全部点击“下一步”即可完成安装: 3. 安装RabbitMQ 以管理员身份运行,然后