首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏技术杂记

    RabbitMQ管理10

    再次尝试发送 [root@h102 ruby]# ruby p.rb [x] Sent 'Done!' [root@h102 ruby]# 查看队列 [root@h102 ruby]# rabbitmqctl list_queues Listing queues ... mq_learning_q 0 ruby_test_q 1 [root@h102 ruby]# 消费队列里的内容(这个进程消费完队列里的内容后,会挂起,等待接收队列里新的内容) [root@h102 ruby]# ruby c.rb

    27420编辑于 2022-04-23
  • 来自专栏技术杂记

    RabbitMQ基础10

    [root@h102 rabbitmq]# 让节点恢复到初始状态(原文是返回处女状态 ) This command resets the RabbitMQ node . Return a RabbitMQ node to its virgin state 必须先停掉RabbitMQ应用,才能成功执行,否则会报错 [root@h102 rabbitmq]# rabbitmqctl Error: mnesia_unexpectedly_running [root@h102 rabbitmq]# echo $? 2 [root@h102 rabbitmq]# 停掉后,可以正常执行 [root@h102 rabbitmq]# rabbitmqctl stop_app Stopping node rabbit@ [root@h102 rabbitmq]# rabbitmqctl reset Resetting node rabbit@h102 ... [root@h102 rabbitmq]#

    35230编辑于 2022-05-04
  • 来自专栏情情说

    RabbitMQ实战:运行和管理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后,会显示日志的路径: ?

    1.2K60发布于 2018-04-27
  • 来自专栏默存

    SpringBoot RabbitMQ 实战

    RabbitMQ RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。 RabbitMQ 七种队列模式 简单模式(Hello World):做最简单的事情,一个生产者对应一个消费者,RabbitMQ相当于一个消息代理,负责将A的消息转发给B。 .rpm 2.查看Erlang版 erl -version 二、安装RabbitMq 1.解压包 xz -d rabbitmq-server-generic-unix-3.7.7.tar.xz tar /sbin:$PATH 3.PATH路径更新 source /etc/profile 4.开启 web 管理插件 rabbitmq-plugins enable rabbitmq_management /rabbitmq-plugins enable rabbitmq_management #后台运行rabbitmq .

    67220编辑于 2022-06-24
  • 来自专栏sktj

    rabbitmq实战指南

    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的版本要一致

    41510编辑于 2022-05-20
  • 来自专栏JavaEdge

    RabbitMQ实战(四) - RabbitMQ & Spring整合开发

    魔都架构师 | 全网30W技术追随者 大厂分布式系统/数据中台实战专家 主导交易系统百万级流量调优 & 车联网平台架构 AIGC应用开发先行者 | 区块链落地实践者 以技术驱动创新,我们的征途是改变世界 实战干货:编程严选网 本文讲解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 中直接进行注入即可 & Spring Cloud Stream整合实战Spring Cloud全家桶在整个中小型互联网公司异常的火爆,Spring Cloud Stream也就渐渐的被大家所熟知,本小节主要来绍RabbitMQ

    2.3K81编辑于 2026-01-29
  • 来自专栏JavaEdge

    RabbitMQ实战(四) - RabbitMQ & Spring整合开发

    (使用rabbitmq 来实现异步rpc功能时候会使用到这个属性)。 与SpringBoot2.x整合实战 7.1 配置详解 publisher-confirms 实现一个监听器监听 broker 给我们返回的确认请求RabbitTemplate.ConfirmCallback & Spring Cloud Stream整合实战 Spring Cloud全家桶在整个中小型互联网公司异常的火爆,Spring Cloud Stream也就渐渐的被大家所熟知,本小节主要来绍RabbitMQ 8.3 RabbitMQ绑定概述 默认情况下,RabbitMQ Binder实现将每个目标映射到TopicExchange。对于每个使用者组,Queue绑定到该TopicExchange。 应用启动类 Barista接口 配置文件 接收 启动Con服务,查看管控台 运行Pro测试代码及结果 9 总结 本文我们学习了Spring AMQP的相关知识,通过实战

    1.6K20编辑于 2022-11-30
  • 来自专栏情情说

    RabbitMQ实战:扩展RabbitMQ与系列总结

    本系列是「RabbitMQ实战:高效部署分布式消息队列」书籍的总结笔记。 本篇是「RabbitMQ实战」系列的最后一篇,主要介绍RabbitMQ插件,了解如何安装和启用它,列举一些常用的插件,以及如何自定义。 在介绍之前,先总结下本系列的主要内容,把它们串起来。 有些场景,对RabbitMQ可用性要求比较高,不容许有消息的丢失,需要了解RabbitMQ的可用性保障和实现。 /rabbitmq-plugins enable <plugin-name> 禁用插件,禁用插件后,需要重启RabbitMQ服务器: 1 . 最后,将交换器注册到RabbitMQRabbitMQ维护了一个注册表,用这张表来跟踪所有的交换器类型及其模块名称,假设将消息发布到fanout交换器上,RabbitMQ会进入注册表,检查由哪个模块来实现

    1.6K70发布于 2018-05-11
  • 来自专栏Redis管理

    RabbitMQ 延迟消息实战

    RabbitMQ 延迟消息实战RabbitMQ Assistant 是一款 RabbitMQ 可视化管理与监控——深入了解您的队列、订阅与消费消息,展示完整的消息流图以及压力测试。 由于队列 queue.normal 设置了过期时间为 10s,在这 10s 内没有消费者消费这条消息,那么判定这条消息为过期。 在真实应用中,对于延迟队列可以根据延迟时间的长短分为多个等级,一般分为 5 秒、10 秒、30 秒、1 分钟、5 分钟、10 分钟、30 分钟、1 小时这几个维度,当然也可以再细化一下。 这里队列分别设置了过期时间为 5 秒、10 秒、30 秒、1 分钟,同时也分别配置了 DLX 和相应的死信队列。 参考资料:RabbitMQ Delayed Messages 101: How to Delay & Schedule Messages Made EasyRabbitMQ实战:高效部署分布式消息队列

    80570编辑于 2023-02-23
  • 来自专栏名山丶深处

    springboot集成rabbitmq实战

    RabbitMQ简介 RabbitMQ使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现(AMQP的主要特征是面向消息、队列、路由、可靠性、安全)。 图一                             图二 RabbitMQ比较重要的几个概念: 虚拟主机:RabbitMQ支持权限控制,但是最小控制粒度为虚拟主机。 服务配置(application.properties) #rabbitmq相关配置 spring.rabbitmq.host=192.168.15.131 spring.rabbitmq.port=5672 分析日志: 从生产者日志第7、10行可以看出,api.core.user和api.core.user.query消息均已发送成功。 从第10行日志可以看出,已经收取到返回的消息,并成功转化为Order对象。 从消费者日志可以看出,已经成功接收到消息并处理完成。 虽然RabbitMQ支持RPC接口调用,但不推荐使用。

    1.5K20发布于 2018-06-20
  • 来自专栏JavaEdge

    RabbitMQ实战 - Confirm机制

    channel.confirmSelect() 在channel上添加监听:addConfirmListener,监听成功和失败的返回结果,根据具体的结果对消息进行重新发送、或记录日志等后续处理 4 代码实战

    1.1K10发布于 2021-02-22
  • 来自专栏JavaEdge

    RabbitMQ实战 - Return机制

    在基础API中的一个关键配置项:Mandatory true,则监听器会接收到路由不可达的消息,然后进行后续处理 false,则broker自动删除该消息 3 代码实战 Con ?

    55120发布于 2021-02-23
  • 来自专栏Java工程师成长之路

    RabbitMQ实战应用技巧

    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

    93121发布于 2019-10-30
  • 来自专栏技术路漫漫

    RabbitMQ 快速入门实战

    long deliveryTag = message.getMessageProperties().getDeliveryTag(); if (user.getUserId() % 10 userId":7,"userName":"用户7"} consumer got msg:{"userId":8,"userName":"用户8"} consumer got msg:{"userId":10 ,"userName":"用户10"} consumer msg nack:7,DemoUser(userId=10, userName=用户10) Java应用模式 简单work模式 springaqmp 官方资料 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

    1K11发布于 2020-07-18
  • 来自专栏Java工程师成长之路

    websocket+rabbitmq实战

    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 onOpen(Session session) throws TimeoutException { log.info("websocket connect"); //10M

    3K10发布于 2019-09-10
  • 来自专栏名山丶深处

    springboot集成rabbitmq实战

    RabbitMQ简介 RabbitMQ使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现(AMQP的主要特征是面向消息、队列、路由、可靠性、安全)。 图一                             图二 RabbitMQ比较重要的几个概念: 虚拟主机:RabbitMQ支持权限控制,但是最小控制粒度为虚拟主机。 服务配置(application.properties) #rabbitmq相关配置 spring.rabbitmq.host=192.168.15.131 spring.rabbitmq.port=5672 分析日志: 从生产者日志第7、10行可以看出,api.core.user和api.core.user.query消息均已发送成功。 从第10行日志可以看出,已经收取到返回的消息,并成功转化为Order对象。 从消费者日志可以看出,已经成功接收到消息并处理完成。 虽然RabbitMQ支持RPC接口调用,但不推荐使用。

    1.9K50发布于 2018-05-22
  • 来自专栏技术杂记

    RabbitMQ集群I10

    拆分集群 本地退出 有时我们有必要从集群中移出某个node,分三步 1 停应用 2 重置node 3 起应用 [root@h102 ~]# rabbitmqctl cluster_status Cluster status of node rabbit@h102 ... [{nodes,[{disc,[rabbit@h101,rabbit@h102]}]}, {running_nodes,[rabbit@h101,rabbit@h102]}, {cluster_name,<<"rabbit@h101.

    19120编辑于 2022-05-04
  • 来自专栏cjz的专栏

    RabbitMQ(Win10)安装

    下载安装包 自己去下载或者下载我的 安装包 秘闻:o71z 安装Erlang的环境 我要知道RabbitMQ 是需要Erlang运行环境的,所以比要安装Erlang 默认即可,点击 Next 配置环境 编辑系统变量path加入路径 自己安装的路径\bin或sbin 测试是否配置成功,打开 cmd 输入: erl 出现版本号即成功~ RabbMQ安装 测试是否成功 首先确保 RabbitMQ 服务是启动状态的,按win键后直接输入服务即可 进入安装目录/sbin 执行命令刚开始安装最好命令顺序和我一样 开启web控制台的访问 rabbitmq-plugins enable rabbitmq_management 查看能使用的用户名和密码 rabbitmqctl list_users 启动RabbitMQ rabbitmqctl start_app 常用命令: 启动:rabbitmqctl start_app

    97340编辑于 2022-12-21
  • 来自专栏springBoot3.0

    Win10安装RabbitMQ

    一、先在官网下载RabbitMQ 官网网址:https://www.rabbitmq.com/download.html 进入官网后往下滑,找到如下页面点击Windows installer下载 二、安装Erlang 1.由于RabbitMQ服务端代码是使用并发式语言Erlang编写的,安装Rabbit MQ的前提是安装Erlang。 但是Erlang选择的版本一定要和RabbitMQ版本匹配,否则会出现未知错误。 2.如何查看Erlang版本与RabbitMQ版本匹配关系,上面RabbitMQ下载的是3.9.11版本。 2.通过cmd进入安装RabbitMQ的sbin中,在后面输入rabbitmq-plugins enable rabbitmq_management命令进行安装。 3.安装好后,运行RabbitMQ即可,进入安装目录的sbin中,双击rabbitmq-server.bat 4.最后访问 http://localhost:15672 即可看到RabbitMQ的管理开始页面了

    56120编辑于 2023-10-20
  • 来自专栏工作经验

    Windows10安装RabbitMQ

    Windows10安装RabbitMQ 本文简略记载下艰辛安装旅程需要注意的点 1、首先需要 安装erlang https://www.erlang.org/downloads 2、设置erlang 的环境变量 变量名: ERLANG_HOME 变量值: 你的erlang安装路径 例如:D:\tool\erl10.5 3、安装RabbitMQ https://www.rabbitmq.com/install-windows.html 4、设置环境变量 变量名: RABBITMQ_HOME 变量值: 你的RabbitMQ安装路径 例如:D:\tool\RabbitMQ Server\rabbitmq_server-3.8.3 最后把添加的两个环境变量添加到系统 path路径中 %ERLANG_HOME%\bin;%RABBITMQ_HOME%\sbin; 5、安装plugins插件 执行: rabbitmq-plugins enable rabbitmq_management 6、启动执行 rabbitmq-server.bat 需要注意点: 工具安装路劲不能包含空格和中文 安装的erlang必须和RabbitMQ版本匹配 https://www.rabbitmq.com

    41910编辑于 2023-07-17
领券