java：brew安装rabbitmq以及简单示例

news2024/11/18 5:41:25

什么是消息队列mq

可以看我之前写的这篇 消息队列MQ

rabbitmq简介

RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。

brew安装rabbitmq

1、安装
官方文档

brew install rabbitmq

这是安装的 log

Management UI: http://localhost:15672
Homebrew-specific docs: https://rabbitmq.com/install-homebrew.html

To start rabbitmq now and restart at login:
  brew services start rabbitmq
Or, if you don't want/need a background service you can just run:
  CONF_ENV_FILE="/opt/homebrew/etc/rabbitmq/rabbitmq-env.conf" /opt/homebrew/opt/rabbitmq/sbin/rabbitmq-server

2、打开 http://localhost:15672
在这里插入图片描述
默认的用户名密码都是 guest，登录后可以在 Admin 那一列菜单内添加自己的用户
在这里插入图片描述

权限

在这里插入图片描述
超级管理员(administrator)
可登陆管理控制台，可查看所有的信息，并且可以对用户，策略(policy)进行操作。

监控者(monitoring)
可登陆管理控制台，同时可以查看rabbitmq节点的相关信息(进程数，内存使用情况，磁盘使用情况等)

策略制定者(policymaker)
可登陆管理控制台, 同时可以对policy进行管理。但无法查看节点的相关信息(上图红框标识的部分)。

普通管理者(management)
仅可登陆管理控制台，无法看到节点信息，也无法对策略进行管理。

其他
无法登陆管理控制台，通常就是普通的生产者和消费者。

创建虚拟主机（Virtual Hosts）

为了让各个用户可以互不干扰的工作，RabbitMQ添加了虚拟主机（Virtual Hosts）的概念。其实就是一个独立的访问路径，不同用户使用不同路径，各自有自己的队列、交换机，互相不会影响。
在这里插入图片描述

交换机类型

1. 直连交换机（Direct Exchange）

特点：

  • 基于路由键（Routing Key）的完全匹配来路由消息。

应用场景：

  • 当消息需要明确指定到某个队列时，使用直连交换机。

举例说明：

  • 假设有一个订单处理系统，其中包含“订单处理”和“订单审核”两个队列。生产者发送一个消息时，指定路由键为“order.process”，那么只有绑定了该路由键的“订单处理”队列会收到消息。如果指定路由键为“order.review”，则只有“订单审核”队列会收到消息。

2. 扇形交换机（Fanout Exchange）

特点：

  • 将消息广播到所有绑定到它的队列，忽略路由键。如果N个队列绑定到某个扇型交换机上，当有消息发送给此扇型交换机时，交换机会将消息的发送给这所有的N个队列

应用场景：

  • 当需要将消息发送给多个队列，且每个队列都需要接收到相同消息的副本时，使用扇出交换机。

举例说明：

  • 假设有一个实时新闻发布系统，包含“新闻订阅者A”和“新闻订阅者B”两个队列。生产者发布一条新闻消息到扇出交换机，那么这条消息将被同时发送到“新闻订阅者A”和“新闻订阅者B”两个队列，实现广播效果。

3. 主题交换机（Topic Exchange）

特点：

  • 基于路由键和通配符（*和#）的模糊匹配来路由消息。

应用场景：

  • 当需要根据消息的不同类型或属性将其路由到不同的队列时，使用主题交换机。

举例说明：

  • 假设有一个日志系统，包含“error.log”、“info.log”和“debug.log”三个队列。生产者发送一条错误日志消息，路由键为“system.error”。此时，绑定了“*.error”或“system.#”的队列将接收到这条消息，因此“error.log”队列会收到它，而“info.log”和“debug.log”则不会（除非它们也绑定了匹配的路由键）。

* (星号) 用来表示一个单词 (必须出现的)
# (井号) 用来表示任意数量（零个或多个）单词

通配的绑定键是跟队列进行绑定的，举个小例子
队列Q1 绑定键为*.TT.* 队列Q2绑定键为 TT.#
如果一条消息携带的路由键为 A.TT.B，那么队列Q1将会收到；
如果一条消息携带的路由键为TT.AA.BB，那么队列Q2将会收到；

4. 头部交换机（Headers Exchange）

特点：

  • 基于消息的头部信息进行匹配，而不是路由键。

应用场景：

  • 当需要根据消息的复杂属性进行路由时，使用头部交换机。这种交换机类型使用较少，因为它需要更复杂的匹配逻辑。

举例说明（假设场景）：

  • 假设有一个消息处理系统，其中消息具有多个头部属性，如“priority”（优先级）、“type”（类型）等。生产者发送一条高优先级的紧急消息，并设置相应的头部属性。此时，只有那些设置了匹配这些头部属性（如“priority=high”）的队列才会接收到这条消息。

RabbitMQ的工作原理

在这里插入图片描述
组成部分说明：
Broker：消息队列服务进程，此进程包括两个部分：Exchange和Queue
Exchange：消息队列交换机，按一定的规则将消息路由转发到某个队列，对消息进行过虑。
Queue：消息队列，存储消息的队列，消息到达队列并转发给指定的消费者
Producer：消息生产者，即生产方客户端，生产方客户端将消息发送
Consumer：消息消费者，即消费方客户端，接收MQ转发的消息。

生产者发送消息流程：
1、生产者和Broker建立TCP连接。
2、生产者和Broker建立通道。
3、生产者通过通道消息发送给Broker，由Exchange将消息进行转发。
4、Exchange将消息转发到指定的Queue（队列）

消费者接收消息流程：
1、消费者和Broker建立TCP连接
2、消费者和Broker建立通道
3、消费者监听指定的Queue（队列）
4、当有消息到达Queue时Broker默认将消息推送给消费者。
5、消费者接收到消息。
6、ack回复

使用

基本配置

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

spring.application.name=zy-rabbitmq

spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=xxx
spring.rabbitmq.password=xxx
#虚拟host 可以不设置,使用server默认host
spring.rabbitmq.virtual-host: JCcccHost

直连交换机示例

创建一个配置文件

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class DirectRabbitConfig {
 
    //队列 起名：TestDirectQueue
    @Bean
    public Queue TestDirectQueue() {
        // durable:是否持久化,默认是false,持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效
        // exclusive:默认也是false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable
        // autoDelete:是否自动删除，当没有生产者或者消费者使用此队列，该队列会自动删除。
        // return new Queue("TestDirectQueue",true,true,false);
 
        //一般设置一下队列的持久化就好,其余两个就是默认false
        return new Queue("TestDirectQueue",true);
    }
 
    //Direct交换机 起名：TestDirectExchange
    @Bean
    DirectExchange TestDirectExchange() {
      //  return new DirectExchange("TestDirectExchange",true,true);
        return new DirectExchange("TestDirectExchange",true,false);
    }
 
    //绑定  
    //将队列和交换机绑定, 并设置用于匹配键：TestDirectRouting
    @Bean
    Binding bindingDirect() {
        return BindingBuilder.bind(TestDirectQueue()).to(TestDirectExchange()).with("TestDirectRouting");
    }
     
    @Bean
    DirectExchange lonelyDirectExchange() {
        return new DirectExchange("lonelyDirectExchange");
    }
}

写个简单的接口进行消息推送（根据需求也可以改为定时任务等等，具体看需求）

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

@RestController
public class SendMessageController {

    //使用RabbitTemplate,这提供了接收/发送等等方法
    @Autowired
    RabbitTemplate rabbitTemplate;  
 
    @GetMapping("/sendDirectMessage")
    public String sendDirectMessage() {
        String messageId = String.valueOf(UUID.randomUUID());
        String messageData = "test message, hello!";
        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        Map<String,Object> map=new HashMap<>();
        map.put("messageId",messageId);
        map.put("messageData",messageData);
        map.put("createTime",createTime);
        //将消息携带绑定键值：TestDirectRouting 发送到交换机TestDirectExchange
        rabbitTemplate.convertAndSend("TestDirectExchange", "TestDirectRouting", map);
        return "ok";
    }
}

在这里插入图片描述
在这里插入图片描述
可以看到消息已经推送到rabbitMq服务器上面了。接下来要消费这个消息了。一般来说要开启另一个服务来消费了，但是我们是练习就在当前服务进行消费。

然后是创建消息接收监听类

@Component
//监听的队列名称 TestDirectQueue
@RabbitListener(queues = "TestDirectQueue")
public class DirectReceiver {
 
    @RabbitHandler
    public void process(Map testMessage) {
        System.out.println("DirectReceiver消费者收到消息  : " + testMessage.toString());
    }
 
}

运行项目，就把这个消息消费掉了。

扇形交换机、主题交换机

和上面的差不多，就先不写了

参考资料

https://blog.csdn.net/weixin_42039228/article/details/123493937

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2169580.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

200smart数据日志的功能

200smart数据日志的功能

称重设备&#xff08;皮带秤&#xff09;读取到的数据值总是一直在跳变&#xff0c;无法正确识别称重传感器读取上来的值来判断产品的重量&#xff0c;虽然在程序中增加了取平均值功能&#xff08;模拟量输入按PLC扫描周期次数求平均值程序&#xff09;&#xff0c;但效果不理想…
阅读更多...
什么是聚集索引？

什么是聚集索引？

什么是聚集索引&#xff1f; 1、聚集索引的特点2、如何确定聚集索引3、性能优势 &#x1f496;The Begin&#x1f496;点点关注&#xff0c;收藏不迷路&#x1f496; 聚集索引是一种特殊的索引&#xff0c;它直接包含了表中的所有数据行。所以&#xff0c;通过聚集索引&#xf…
阅读更多...
代码随想录冲冲冲 Day56 图论Part8

代码随想录冲冲冲 Day56 图论Part8

117. 软件构建 这道题是使用拓扑排序的方法 看多个任务有优先级的情况下 怎么排序 对应到这道题就是文件排序 首先要记录每一个点的入度&#xff0c;当一个点的入度为0时&#xff0c;就说明这个点是顶点 然后记录每一个点向那些点相连 之后建立一个queue 寻找一个入度为0的…
阅读更多...
弹簧状态检测系统源码分享

弹簧状态检测系统源码分享

弹簧状态检测检测系统源码分享 [一条龙教学YOLOV8标注好的数据集一键训练_70全套改进创新点发刊_Web前端展示] 1.研究背景与意义 项目参考AAAI Association for the Advancement of Artificial Intelligence 项目来源AACV Association for the Advancement of Computer Vis…
阅读更多...
Linux中安装ffmpeg

Linux中安装ffmpeg

Linux中安装ffmpeg 一、下载二、安装三、测试 一、下载 先到这里下载ffmpeg。 二、安装 先将上传到服务器的某一目录&#xff0c;我这里是&#xff1a; /usr/local/ffmpeg 然后解压&#xff0c;解压命令如下&#xff1a; tar -xvf “你的安装包名称”我的是&#xff1a; ta…
阅读更多...
流浪软件uniaccess agent 删除

流浪软件uniaccess agent 删除

cmd的C盘找不到就用git rm -rf 之后&#xff0c;只剩下 俩文件夹删不掉 然后360软件就看到了&#xff0c;可惜卸载失败 然后360文件就找到了&#xff0c;彻底删除 再回git 查看 方法 https://blog.51cto.com/u_16099347/11352333 https://blog.csdn.net/xioayu96/article/…
阅读更多...
Linux下线程间的通信

Linux下线程间的通信

为什么需要线程通信&#xff1f; 线程是操作系统调度的最小单元&#xff0c;拥有自己的栈空间。如果线程之间孤立运行&#xff0c;可能会导致资源浪费。线程需要协调工作以完成共同的任务&#xff0c;这就需要线程间相互通信 在 Linux 系统中&#xff0c;线程间通信&#xff…
阅读更多...
请问这张图是ai绘画吗？

请问这张图是ai绘画吗？

小白可做&#xff01;全自动AI影视解说一键成片剪辑工具https://docs.qq.com/doc/DYnl6d0FLdHp0V2ll 先来结论&#xff0c;找到用这图的某宝店老板了&#xff0c;老板说不是AI画的。 真相只有一个&#xff0c;有图有真相 再来化身柯南&#xff0c;看看寻找答案的过程 要判断这张…
阅读更多...
重考！CSP-J/S 2024第一轮认证泄题后续进展及疑问

重考！CSP-J/S 2024第一轮认证泄题后续进展及疑问

2024年9月26日晚间&#xff0c;NOI官网发布了”对部分被认证者进行CSP-J/S 2024第一轮重新认证的公告“&#xff0c;对少儿编程培训机构老师举报陕西鸿泉教育培训机构泄题一事进行了最新的回应。 对涉嫌参加该机构培训的学生的CSP-J/S 2024第一轮入门级、提高级认证成绩不予认可…
阅读更多...
＜＜编码＞＞ 第 21 章 总线连接(Get on the Bus) 示例电路

＜＜编码＞＞ 第 21 章 总线连接(Get on the Bus) 示例电路

比较器 info::操作说明 鼠标单击开关切换开合状态 鼠标单击逻辑输入切换 0|1 状态 若上方和左边的输入相同, 则输出高电平 primary::在线交互操作链接 https://cc.xiaogd.net/?startCircuitLinkhttps://book.xiaogd.net/code-hlchs-examples/assets/circuit/code-hlchs-ch21-0…
阅读更多...
力扣（LeetCode)每日一题 2207. 字符串中最多数目的子序列

力扣（LeetCode)每日一题 2207. 字符串中最多数目的子序列

题目链接https://leetcode.cn/problems/maximize-number-of-subsequences-in-a-string/description/?envTypedaily-question&envId2024-09-24 给你一个下标从 0 开始的字符串 text 和另一个下标从 0 开始且长度为 2 的字符串 pattern &#xff0c;两者都只包含小写英文字母…
阅读更多...
Vue中使用Hls.js进行视频直播的播放

Vue中使用Hls.js进行视频直播的播放

HLS.js使用文档 1、安装组件&#xff1a; npm install hls.js --save2、引入组件&#xff1a; import Hls from hls.js3、使用组件&#xff1a; // DOM&#xff1a; <video id"video" controls loop"false"></video> // DATA: let hls nul…
阅读更多...
[深度学习]卷积神经网络CNN

[深度学习]卷积神经网络CNN

1 图像基础知识 import numpy as np import matplotlib.pyplot as plt # 图像数据 #imgnp.zeros((200,200,3)) imgnp.full((200,200,3),255) # 可视化 plt.imshow(img) plt.show() # 图像读取 imgplt.imread(img.jpg) plt.imshow(img) plt.show() 2 CNN概述 卷积层convrelu池…
阅读更多...
实战OpenCV之色彩空间转换

实战OpenCV之色彩空间转换

基础入门 色彩空间是描述颜色的一种数学模型&#xff0c;它定义了颜色的三个或更多维度&#xff0c;比如&#xff1a;亮度、色相和饱和度等。最著名的色彩空间之一是RGB&#xff0c;它基于人眼对光的感知原理&#xff0c;通过红、绿、蓝三种基本颜色的不同强度组合来表示几乎所…
阅读更多...
【HarmonyOS】鸿蒙仿iOS线性渐变实现

【HarmonyOS】鸿蒙仿iOS线性渐变实现

【HarmonyOS】仿照IOS中可以通过输入start&#xff08;0&#xff0c;0&#xff09;&#xff0c;end&#xff08;1&#xff0c;1&#xff09;获取角度到.linearGradient&#xff0c;从而实现左上到右下渐变 class Point {x: number 0y: number 0 }Entry Component struct Page…
阅读更多...
开源链动 2+1 模式 S2B2C 商城小程序：激活 KOC，开启商业新征程

开源链动 2+1 模式 S2B2C 商城小程序：激活 KOC，开启商业新征程

摘要&#xff1a;本文深入探讨了 KOC 在立体连接中的重要性&#xff0c;以及如何通过开源链动 21 模式 S2B2C 商城小程序发现和找到更多的 KOC。强调了历史积累强关系和快速强化强关系的方法&#xff0c;并阐述了该商城小程序在推动商业发展中的关键作用。 一、引言 在当今竞争…
阅读更多...
mysql 内存被打满记录

mysql 内存被打满记录

一&#xff1a;早上收到报警&#xff1a;提示&#xff1a;您的云数据库RDS的1个实例因存储空间满将被锁定&#xff0c;请关注实例的存储空间使用情况&#xff0c;可通过存储扩容或空间清理解除锁定。后续查看错误日志如下&#xff1a;磁盘没有空间了 没有多余的空间写binlog和…
阅读更多...
2024年下安徽省事业编考试报名流程（电脑）

2024年下安徽省事业编考试报名流程（电脑）

2024年下安徽省事业编考试报名流程&#xff08;电脑&#xff09;
阅读更多...
极狐GitLab 17.4 升级指南

极狐GitLab 17.4 升级指南

GitLab 是一个全球知名的一体化 DevOps 平台&#xff0c;很多人都通过私有化部署 GitLab 来进行源代码托管。极狐GitLab https://dl.gitlab.cn/6y2wxugm 是 GitLab 在中国的发行版&#xff0c;专门为中国程序员服务。可以一键式部署极狐GitLab。 本文分享极狐GitLab 17.4 升级…
阅读更多...
【JVM】垃圾释放方式：标记-清除、复制算法、标记-整理、分代回收

【JVM】垃圾释放方式：标记-清除、复制算法、标记-整理、分代回收

文章目录 1. 标记-清除2. 复制算法4. 标记-整理4. 分代回收 把标记为垃圾的对象的内存空间进行释放。主要有三种释放方式 1. 标记-清除 把标记为垃圾的对象&#xff0c;直接释放掉&#xff08;最朴素的做法&#xff09; 此时就是把标记为垃圾的对象所对应的内存空间直接释放。…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023