Window10 系统 RabbitMQ的安装和简单使用

这篇具有很好参考价值的文章主要介绍了Window10 系统 RabbitMQ的安装和简单使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1、下载 & 安装 Erlang

因为RabbitMQ的服务端是基于 Erlang编写的,所以,首先需要安装Erlang。

1)下载

下载地址如下:

https://www.erlang.org/downloads

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java

此处下载比较慢,可以参考如下百度网盘:
链接:https://pan.baidu.com/s/1oXq5QX3IlzRq5L-mk1gC4Q
提取码:luna

2)安装

选择相应的安装目录,一路next即可。

3)配置环境变量

在系统变量中新建变量
变量名(N):ERLANG_HOME
变量值(V):H:\SW_install\erl-24.1

注意:变量值需要根据自己的实际情况进行修改

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java
;%ERLANG_HOME%\bin 添加到 Path 变量值的最后。

4)验证环境变量配置的正确性
echo %ERLANG_HOME%

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java


2、下载 & 安装 RabbitMQ

1)下载

下载地址如下:

https://www.rabbitmq.com/install-windows.html#installer

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java

2)安装

选择相应的安装目录,一路next即可。

3)配置环境变量

在系统变量中新建变量
变量名(N):RABBITMQ_SERVER
变量值(V):H:\SW_install\RabbitMQ Server\rabbitmq_server-3.9.7

注意:变量值需要根据自己的实际情况进行修改

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java
;%RABBITMQ_SERVER%\sbin 添加到 Path 变量值的最后。Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java

4)验证环境变量配置的正确性
echo %RABBITMQ_SERVER%

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java

5)安装 rabbitmq-plugins

cmd命令打开命令行窗口,进入到rabbitmq的安装bin目录(我的是:H:\SW_install\RabbitMQ Server\rabbitmq_server-3.9.7\sbin)

执行如下命令,进行插件安装:

rabbitmq-plugins.bat enable rabbitmq_management

如果此处报如下错误:
ERLANG_HOME not set correctly
在确认配置的环境变量没问题的情况下,从C:目录逐层到RabbitMQ的安装bin目录,再次执行插件安装,即可解决。

6)启动 RabbitMQ 服务
net start RabbitMQ

或者
在rabbitmq的sbin目录下,双击执行 rabbitmq-server.bat 文件。

7)停止 RabbitMQ 服务
net stop RabbitMQ
8)查看服务状态
rabbitmqctl status
9)页面访问 RabbitMQ

http://localhost:15672
账号/密码:guest/guest

Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java
登录后,页面如下:
Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java
Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java


3、RabbitMQ 的简单使用

1)RabbitMQ 的 pom 引用
<!-- https://mvnrepository.com/artifact/com.rabbitmq/amqp-client -->
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.13.1</version>
</dependency>
2)消息发送方
package com.miracle.luna.rabbitmq;

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

import java.nio.charset.StandardCharsets;

/**
 * @author Miracle Luna
 * @date 2021/10/19
 */
public class SendMQ {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception{
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");

        final Connection connection = factory.newConnection();
        final Channel channel = connection.createChannel();
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        String message = "Hello, RabbitMQ!";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
        System.out.println("Send '" + message + "'");

        channel.close();
        connection.close();
    }
}

运行结果如下:

Send 'Hello, RabbitMQ!'
3)消息接收方
package com.miracle.luna.rabbitmq;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.nio.charset.StandardCharsets;

/**
 * @author Miracle Luna
 * @date 2021/10/19
 */
public class RecvMQ {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception{
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");

        final Connection connection = factory.newConnection();
        final Channel channel = connection.createChannel();
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        System.out.println("Waiting for messages...");

        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, StandardCharsets.UTF_8);
                System.out.println("Received '" + message + "'");
            }
        };

        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}

运行结果如下:

Waiting for messages...
Received 'Hello, RabbitMQ!'

可以在Queues页签中,看到所有队列中的消息数量
Window10 系统 RabbitMQ的安装和简单使用,JAVA,Tools,rabbitmq,java


4、常用命令

1)查看用户列表:rabbitmqctl list_users
2)新增一个用户:rabbitmqctl add_user root password
3)删除一个用户:rabbitmqctl delete_user test
4)修改用户密码:rabbitmqctl change_password root 123456
5)授予管理员角色:rabbitmqctl set_user_tags root administrator
6)授予用户权限:rabbitmqctl set_permissions -p / root “.” “.” “.*”
7)查看队列列表:rabbitmqctl list_queues
8)删除一个队列:rabbitmqctl delete_queue test
9)重置(如果忘记密码,可以进行应用重置,但是数据会丢失,慎用!!!):
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app文章来源地址https://www.toymoban.com/news/detail-566792.html



到了这里,关于Window10 系统 RabbitMQ的安装和简单使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Window10安装linux子系统及子系统安装1Panel面板

    原文地址:Window10安装linux子系统及子系统安装1Panel面板 - Stars-One的杂货小窝 最近看到halo博客发布了2.10.0,终于是新增了个备份功能,于是有了念头想要升级下 但是目前我还是使用halo1.5版本,所以跨版本迁移可能会有问题,官方提议还是先用个测试环境进行测试验证是否有问题 但

    2024年02月08日
    浏览(54)
  • window10安装并使用oracle

    1、现在oracle19c或者21c,下载链接如下 Database Software Downloads | Oracle 中国 2、安装好之后, 2.1PL/SQL连接方式 命令窗口输入sqlplus conn as sysdba 2.2DBeaver连接 输入IP、 端口默认1521 数据库默认是ORCL 用户名是system 角色是Normal 密码就是安装时输入的 3、使用oracle

    2024年02月11日
    浏览(37)
  • Window server 2008 R2 无法安装tools

      方法一:重新安装包含sp1的系统镜像   方法二: 安装sp1补丁     浏览器无法下载直接复制链接到下载器下载  安装   安装vmtools出现新的问题\\\" Windows 无法验证此驱动程序软件的发布者 \\\"   安装补丁 https://www.catalog.update.microsoft.com/Search.aspx?q=kb4474419 “KB4474419” 解决问题 现

    2024年02月13日
    浏览(40)
  • 微软官网U启动制作工具安装window10系统

    1.登录微软官方网站: https://www.microsoft.com/zh-cn/software-download/windows10

    2024年02月11日
    浏览(52)
  • window10下安装银河麒麟高级服务器操作系统(飞腾版)V10

     坑:我们经常使用的电脑CPU是x86架构的,然后我们安装x86架构的64位处理器的操作系统直接使用VMware等虚拟软件进行虚拟,而对与不同的CPU架构的arm架构的操作系统,可以使用QEMU模拟器模拟一个arm环境 2.1 下载QEMU软件 QEMU模拟器安装包 2.2 下载UEFI(BIOS的替代方案) UEFI下载

    2024年02月07日
    浏览(75)
  • Window10下FFMPEG的安装与使用

    FFmpeg是一套可以用来记录、转换数字音频、视频,并能将其转化为流的开源计算机程序。采用LGPL或GPL许可证。它提供了录制、转换以及流化音视频的完整解决方案。它包含了非常先进的音频/视频编解码库libavcodec,为了保证高可移植性和编解码质量,libavcodec里很多code都是从

    2024年02月02日
    浏览(39)
  • 创建台虚拟机并安装上window10系统(NETBASE 第一课)

    虚拟机(Virtual Machine)是一种基于软件的模拟技术,它可以将一台物理计算机模拟成多个虚拟计算机运行不同的操作系统和应用程序,从而实现资源的虚拟化和隔离。在虚拟机中,每个虚拟计算机都拥有自己的独立的操作系统和应用程序,并且可以独立地运行和管理。 虚拟机

    2024年02月13日
    浏览(55)
  • window10 使用docker 本地安装部署mongodb数据库

    一、window10 安装docker 可以参看笨鸟教程【Windows Docker 安装】 安装完后的Docker Desktop是这个样子: 原始的docker镜像拉取仓库速度较慢,为了方便docker拉取镜像,可以设置国内的加速镜像,如:阿里 云、有道等【镜像加速】: 二、docker下载运行mongodb镜像 1 直接在 windows powerShel

    2024年02月03日
    浏览(46)
  • 在Window10和Window11系统,WPF使用Viewport3D 渲染失败问题解决方案

            最近遇到个棘手的问题:在供应商提供的戴尔optiplex 3000的12代处理器主机的集成显卡Intel(R) UHD Graphics 770上使用Viewport3D 渲染失败(3D模型显示不了,或者是显示不全),之前开发验证使用的是集成显卡Intel(R) UHD Graphics 630、集成显卡Intel(R) HD Graphics 4600、集成显卡Intel

    2024年02月08日
    浏览(60)
  • RabbitMQ安装与简单使用

    可以访问官网查看下载信息rabbitmq官网 选择合适的版本, 注意:rabbitmq需要下载一个Erlang才能使用 我自己是在一下两个连接中下载的 rabbitmq 3.8.8 erlang 21.3.8.15 需要下载其他版本的同学注意erlang版本是否匹配,可以访问该链接查询匹配信息版本匹配信息 对erlang进行安装 下载以

    2024年02月07日
    浏览(32)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包