收回权限 不使用 -p 指定vhost时,默认会使用 / ,而不是清除所有 [root@h102 ~]# rabbitmqctl list_user_permissions mq Listing permissions for user "mq" ... / ^mq.* .* .* mq_test .* .* .* [root@h102 ~]# rabbitmqctl clear_permissions -p / mq Clearing permissions for user "mq" in vhost
-c /usr/lib/rabbitmq/bin/rabbitmq-server rabbitmq 4280 0.0 0.0 106100 1336 ? Ss 22:07 0:00 \_ /bin/sh -e /usr/lib/rabbitmq/bin/rabbitmq-server rabbitmq 4384 2.5 -- -pa /usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/sbin/.. Ss 22:07 0:00 \_ inet_gethost 4 rabbitmq 4471 0.0 0.0 12896 644 ? S 22:07 0:00 \_ inet_gethost 4 [root@h102 rabbitmq]# cat /proc/2995/limits
创建用户 [root@rabbitmq ~]# rabbitmqctl list_users Listing users ... cooper [] guest [administrator] [root @rabbitmq ~]# rabbitmqctl add_user mqmonitor mqpass Creating user "mqmonitor" ... [root@rabbitmq ~]# rabbitmqctl list_users Listing users ... cooper [] guest [administrator] mqmonitor [] [root@rabbitmq ~]# 用户赋权 [root@rabbitmq ~]# rabbitmqctl set_user_tags mqmonitor monitoring Setting ,会出现RabbitMQ的认证窗口 正确输入密码后,就可以看到管理界面
本系列是「RabbitMQ实战:高效部署分布式消息队列」书籍的总结笔记。 地址: spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password =guest spring.rabbitmq.publisher-confirms=true spring.rabbitmq.virtual-host=/ LogRabbitConfig实现 使用Spring 另外,rabbitmq提供了管理界面插件,更方便的查看各种统计,可以通过下面的命令开启: 1 sudo . /rabbitmq-plugins enable rabbitmq_management ? 查看日志 可以在文件系统中查看日志,启动rabbitmq后,会显示日志的路径: ?
RabbitMQ RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。 /sbin:$PATH 3.PATH路径更新 source /etc/profile 4.开启 web 管理插件 rabbitmq-plugins enable rabbitmq_management /rabbitmq-plugins enable rabbitmq_management #后台运行rabbitmq . ; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.RabbitListener; ; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.RabbitListener;
RABBITMQ_NODE_PORT 5672 RABBITMQ_DIST_PORT 25672 RABBITMQ_NODENAME RABBITMQ_CONF_ENV_FILE RABBITMQ_CONFIG_FILE #没有.config RABBITMQ_MNESIA_BASE RABBITMQ_MNESIA_DIR RABBITMQ_LOG_BASE RABBITMQ_LOGS RABBITMQ_PLUGINS_DIR ----常用配置 CONFIG_FILE=/rabbitmq/rabbitmq CONFIG_ENV_FILE=/rabbitmq/rabbitmq-env.conf LOG_BASE=/rabbitmq enable rabbitmq_federation rabbitmq-plugins enable rabbitmq_federation_management rabbitmq-plugins enable rabbitmq_shovel rabbitmq-plugins enable rabbitmq_shovel_management 集群种erlang和rabbitmq的版本要一致
实战干货:编程严选网 本文讲解RabbitMQ如何与Spring系的框架体系进行整合(RabbitMQ整合Spring AMQP实战,RabbitMQ整合Spring Boot实战 ,RabbitMQ整合 Spring Cloud实战),涉及实际工作中需要注意的细节点,与最佳实战应用 1 你将学到 RabbitMQ 整合 Spring AMQP实战 RabbitMQ 整合 Spring Boot实战 RabbitMQ 整合 Spring Cloud实战 2 SpringAMQP用户管理组件 - RabbitAdmin RabbitAdmin 类可以很好的操作 rabbitMQ,在 Spring 中直接进行注入即可 例如添加交换机、删除一个绑定、清空一个队列里的消息等等 依赖结构 图片 RabbitAdmin实现了4个Interface: AmqpAdmin, ApplicationContextAware, ApplicationEventPublisherAware & Spring Cloud Stream整合实战Spring Cloud全家桶在整个中小型互联网公司异常的火爆,Spring Cloud Stream也就渐渐的被大家所熟知,本小节主要来绍RabbitMQ
例如添加交换机、删除一个绑定、清空一个队列里的消息等等 依赖结构 RabbitAdmin实现了4个Interface: AmqpAdmin ApplicationContextAware ApplicationEventPublisherAware RabbitTemplate 在 Spring 整合时需要实例化,但是在 Springboot 整合时,在配置文件里添加配置即可 先声明bean 测试 4 SpringAMQP消息容器-SimpleMessageListenerContainer 与SpringBoot2.x整合实战 7.1 配置详解 publisher-confirms 实现一个监听器监听 broker 给我们返回的确认请求RabbitTemplate.ConfirmCallback & Spring Cloud Stream整合实战 Spring Cloud全家桶在整个中小型互联网公司异常的火爆,Spring Cloud Stream也就渐渐的被大家所熟知,本小节主要来绍RabbitMQ 应用启动类 Barista接口 配置文件 接收 启动Con服务,查看管控台 运行Pro测试代码及结果 9 总结 本文我们学习了Spring AMQP的相关知识,通过实战对
本系列是「RabbitMQ实战:高效部署分布式消息队列」书籍的总结笔记。 本篇是「RabbitMQ实战」系列的最后一篇,主要介绍RabbitMQ插件,了解如何安装和启用它,列举一些常用的插件,以及如何自定义。 在介绍之前,先总结下本系列的主要内容,把它们串起来。 有些场景,对RabbitMQ可用性要求比较高,不容许有消息的丢失,需要了解RabbitMQ的可用性保障和实现。 /rabbitmq-plugins enable <plugin-name> 禁用插件,禁用插件后,需要重启RabbitMQ服务器: 1 . 最后,将交换器注册到RabbitMQ,RabbitMQ维护了一个注册表,用这张表来跟踪所有的交换器类型及其模块名称,假设将消息发布到fanout交换器上,RabbitMQ会进入注册表,检查由哪个模块来实现
RabbitMQ 延迟消息实战RabbitMQ Assistant 是一款 RabbitMQ 可视化管理与监控——深入了解您的队列、订阅与消费消息,展示完整的消息流图以及压力测试。 第二种选择是使用官方的 RabbitMQ 延迟消息插件。本文详细介绍了 RabbitMQ 延迟消息。TOC什么是 RabbitMQ? RabbitMQ 的主要特性以下是 RabbitMQ 的一些特性:集群:RabbitMQ 中的集群在设计时考虑了两个目标。 将插件复制到 RabbitMQ 的插件文件夹,然后运行以下命令启用它:# 下载插件wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange 参考资料:RabbitMQ Delayed Messages 101: How to Delay & Schedule Messages Made EasyRabbitMQ实战:高效部署分布式消息队列
RabbitMQ简介 RabbitMQ使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现(AMQP的主要特征是面向消息、队列、路由、可靠性、安全)。 图一 图二 RabbitMQ比较重要的几个概念: 虚拟主机:RabbitMQ支持权限控制,但是最小控制粒度为虚拟主机。 服务配置(application.properties) #rabbitmq相关配置 spring.rabbitmq.host=192.168.15.131 spring.rabbitmq.port=5672 RabbitMQ的默认交换机,直接使用routingKey匹配队列。 安装RabbitMQ请参考:CentOS在线安装RabbitMQ3.7 本帖源代码:https://gitee.com/skychenjiajun/spring-boot
上开启确认模式:channel.confirmSelect() 在channel上添加监听:addConfirmListener,监听成功和失败的返回结果,根据具体的结果对消息进行重新发送、或记录日志等后续处理 4 代码实战 Con ?
在基础API中的一个关键配置项:Mandatory true,则监听器会接收到路由不可达的消息,然后进行后续处理 false,则broker自动删除该消息 3 代码实战 Con ?
RabbitMQ实战应用技巧 1.1. 前言 由于项目原因,之后会和RabbitMQ比较多的打交道,所以让我们来好好整理下RabbitMQ的应用实战技巧,尽量避免日后的采坑 1.2. =localhost:5672 spring.rabbitmq.username=user spring.rabbitmq.password=123456 spring.rabbitmq.virtual-host =/ spring.rabbitmq.connection-timeout=1000 ##设置监听限制:最大10,默认5 spring.rabbitmq.listener.simple.concurrency =5 spring.rabbitmq.listener.simple.max-concurrency=10 spring.rabbitmq.publisher-confirms=true spring.rabbitmq.publisher-returns =true spring.rabbitmq.template.mandatory=true spring.rabbitmq.listener.simple.acknowledge-mode=manual
纯java应用中work、publisher confirm模式的示例 延迟消息队列示例 基础环境搭建 本文基于docker来安装RabbitMQ,通过pull当前最新版本rabbitmq:3.8.5- :3.8.5-management 同时,如有需要,也可以通过-e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password来指定相关的默认用户名称和密码 ,拷贝到容器中 docker cp E:\dev\2try\backends\hiboot\other\rabbitmq\rabbitmq_delayed_message_exchange-3.8.0. 官方资料 https://www.rabbitmq.com/getstarted.html rabbitmq社区插件 https://www.rabbitmq.com/community-plugins.html 延迟消息插件详情 https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/tag/v3.8.0rabbitmq
1. websocket+rabbitmq实战 1.1. 前言 接到的需求是后台定向给指定web登录用户推送消息,且可能同一账号会登录多个客户端都要接收到消息 1.2. 遇坑 基于springboot环境搭建的websocket+rabbitmq,搭建完成后发现websocket每隔一段时间会断开,看网上有人因为nginx的连接超时机制断开,而我这似乎是因为长连接空闲时间太长而断开 正式代码 1.3.1. rabbimq部分 application.properties配置 spring.rabbitmq.addresses = i.tzxylao.com:5672 spring.rabbitmq.username = admin spring.rabbitmq.password = 123456 spring.rabbitmq.virtual-host = / spring.rabbitmq.connection-timeout orderChannel"; } } 消息监听类 /** * @author laoliangliang * @date 2019/3/29 11:38 */ @Component @Slf4j
RabbitMQ简介 RabbitMQ使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现(AMQP的主要特征是面向消息、队列、路由、可靠性、安全)。 图一 图二 RabbitMQ比较重要的几个概念: 虚拟主机:RabbitMQ支持权限控制,但是最小控制粒度为虚拟主机。 服务配置(application.properties) #rabbitmq相关配置 spring.rabbitmq.host=192.168.15.131 spring.rabbitmq.port=5672 RabbitMQ的默认交换机,直接使用routingKey匹配队列。 安装RabbitMQ请参考:CentOS在线安装RabbitMQ3.7 本帖源代码:https://gitee.com/skychenjiajun/spring-boot
其它端口也可以手动指定来避免冲突 Note: that if you have RabbitMQ opening any ports other than AMQP, you’ll need to configure those not to clash as well - for example: $ RABBITMQ_NODE_PORT=5672 RABBITMQ_SERVER_START_ARGS=”-rabbitmq_management listener [{port,15672}]” RABBITMQ_NODENAME=rabbit rabbitmq-server -detached $ RABBITMQ_NODE_PORT=5673 RABBITMQ_SERVER_START_ARGS=”-rabbitmq_management listener [{port,15673}]” RABBITMQ_NODENAME=hare rabbitmq-server The default port for this traffic in RabbitMQ is 20000 higher than RABBITMQ_NODE_PORT (i.e. 25672 by
EmitLogDirect.cs using System;using System.Linq;using RabbitMQ.Client;using System.Text; class EmitLogDirect ReceiveLogsDirect.cs using System;using RabbitMQ.Client;using RabbitMQ.Client.Events;using System.Text To exit press CTRL+C 参考网址: https://www.rabbitmq.com/tutorials/tutorial-four-dotnet.html
{partitions,[]}] [root@h102 ~]# ---- 创建集群 首先关掉本地应用 rabbitmqctl stop_app [root@h102 ~]# /etc/init.d/rabbitmq-server stop Stopping rabbitmq-server: RabbitMQ is not running rabbitmq-server. [root@h102 ~]# /etc/init.d/rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server.