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

    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 .

    67320编辑于 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 可视化管理与监控——深入了解您的队列、订阅与消费消息,展示完整的消息流图以及压力测试。 第二种选择是使用官方的 RabbitMQ 延迟消息插件。本文详细介绍了 RabbitMQ 延迟消息。TOC什么是 RabbitMQRabbitMQ 的主要特性以下是 RabbitMQ 的一些特性:集群:RabbitMQ 中的集群在设计时考虑了两个目标。 将插件复制到 RabbitMQ 的插件文件夹,然后运行以下命令启用它:# 下载插件wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange 参考资料: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 RabbitMQ的默认交换机,直接使用routingKey匹配队列。 安装RabbitMQ请参考:CentOS在线安装RabbitMQ3.7 本帖源代码:https://gitee.com/skychenjiajun/spring-boot

    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 快速入门实战

    纯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

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

    websocket+rabbitmq实战

    1. websocket+rabbitmq实战 1.1. 前言   接到的需求是后台定向给指定web登录用户推送消息,且可能同一账号会登录多个客户端都要接收到消息 1.2. 遇坑 基于springboot环境搭建的websocket+rabbitmq,搭建完成后发现websocket每隔一段时间会断开,看网上有人因为nginx的连接超时机制断开,而我这似乎是因为长连接空闲时间太长而断开 超过一分钟会断线,前端发起请求重连 服务器正常,客户端关闭或注销,服务器正常收到通知,去除对应客户端session 服务器异常,客户端正常,客户端发现连不上服务器会尝试重连3次,3次都连不上放弃重连 rabbitmq 正式代码 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

    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 RabbitMQ的默认交换机,直接使用routingKey匹配队列。 安装RabbitMQ请参考:CentOS在线安装RabbitMQ3.7 本帖源代码:https://gitee.com/skychenjiajun/spring-boot

    1.9K50发布于 2018-05-22
  • 来自专栏情情说

    RabbitMQ实战:理解消息通信

    本系列是「RabbitMQ实战:高效部署分布式消息队列」书籍的总结笔记。 从本篇开始总结「RabbitMQ实战」系列的阅读笔记,RabbitMQ是一个开源的消息代理和队列服务器,可以通过基本协议在完全不同的应用之间共享数据,可以将作业排队以便让分布式服务进行处理。 还有一种场景,在接收到消息后,如果不想处理,可以通过下面方式处理: 把消费者从RabbitMQ服务器断开连接,,这样RabbitMQ会自动将消息入队并发送给另外一个消费者; 如果不想发送给其他消费者处理 虚拟主机 每个RabbitMQ服务器都能创建虚拟消息服务器,称为虚拟主机(vhost),每个RabbitMQ本质上是一个mini版的RabbitMQ服务器,拥有自己的队列、交换器、绑定,还有自己的权限机制 RabbitMQ通过「发送方确认模式」来解决上面的问题。

    1.3K121发布于 2018-04-27
  • 来自专栏JavaEdge

    RabbitMQ实战(二)-基础概念

    RabbitMQ RabbitMQ是一个开源的消息代理和队列服务器,通过普通协议在完全不同的应用之间共享数据,使用Erlang语言编写,并且基于AMQP协议. 1.1 大厂们共同的抉择 滴滴、美团、头条 // 切换到MQ目录,注意你的安装版本可能不是3.7.15 cd /usr/local/Cellar/rabbitmq/3.7.15/ // 启用rabbitmq management插件 RabbitMQ的高性能之道是如何做到的?什么是AMPQ高级协议?AMPQ核心概念是什么?RabbitMQ整体架构模型是什么样子的?RabbitMQ消息是如何流转的? RabbitMQ安装与使用命令行与管控台,RabbitMQ消息生产与消费,RabbitMQ交换机详解,RabbitMQ队列、绑定、虚拟主机、消息等... 通过本文的学习,希望大家对RabbitMQ有一个整体的感知! 参考 RabbitMQ官网 mac + RabbitMQ 安装

    1.1K72发布于 2019-06-29
  • 来自专栏JavaEdge

    RabbitMQ实战-消费端限流

    1 消息过载场景 假设Rabbitmq服务器有上万条未处理的消息,随便打开一个消费端,会造成巨量消息瞬间全部推送过来,然而我们单个客户端无法同时处理这么多数据。 因此,我们需要Con限流 2 Con限流机制 RabbitMQ提供了一种qos (服务质量保证)功能,在非自动确认消息的前提下,若一定数目的消息 (通过基于Con或者channel设置Qos的值) 未被确认前 prefetchCount: 一次最多能处理多少条消息 global: 是否将上面设置true应用于channel级别还是取false代表Con级别 prefetchSize和global这两项,RabbitMQ 参数multiple表示是否批量签收,由于我们是一次处理一条消息,所以设置为false 3 代码实战 自定义Con ? Con ? Pro ? 启动Con,查看管控台 ? ?

    97210发布于 2021-02-23
  • 来自专栏coding

    RabbitMQ实战5.路由

    继上篇 RabbitMQ实战4.发布与订阅 交换机的路由功能 注意!交换机为匿名交换机时,routing_key指的是队列名,这只是一个特例!这个参数的本意是路由键名!

    36120发布于 2018-08-22
  • 来自专栏JavaEdge

    RabbitMQ实战(三)-高级特性

    所以Con肯定需要做一些限流措施,否则如果超出最大负载,可能导致Con性能下降,服务器卡顿甚至崩溃等一系列严重后果 因此,我们需要限流 7.1.2 Con - 限流机制 RabbitMQ提供了一种qos 支持消息的过期时间,在消息发送时可以进行指定 RabbitMQ支持为每个队列设置消息的超时时间,从消息入队列开始计算,只要超过了队列的超时时间配置,那么消息会被自动清除 9.2 管控台演示 新增一个Q 会自动地将该消息重新发布到设置的Exchange,进而被路由到另一个队列 可以监听这个队列中的消息做相应的处理.该特性可以弥补RabbitMQ 3.0以前支持的immediate参数的功能 10.4 11 总结 本文专注RabbitMQ高级特性的学习 首先介绍了大厂在实际使用中是如何保障消息投递成功和幂等性的,以及对RabbitMQ的确认消息、返回消息、ACK与重回队列、消息的限流,以及对超时时间、 参考 RabbitMQ 100% 投递成功方案详解 RabbitMQ 从入门到精通(二) RabbitMQ 幂等性概念及业界主流解决方案 RabbitMQ从入门到精通(三) 更多内容请关注JavaEdge

    1.9K91发布于 2019-07-01
  • 来自专栏情情说

    RabbitMQ实战:性能和安全

    本系列是「RabbitMQ实战:高效部署分布式消息队列」书籍的总结笔记。 前两篇介绍了RabbitMQ在可用性、监控方面的考虑,这是基础保障,因为在某些场景下是不容许丢失消息的,但它和性能往往是对立的,需要根据业务场景做取舍。 比如,RabbitMQ接收到AMQP客户端的TCP连接时,会创建一个进程进行管理该连接,同时,会有很多Erlang进程来处理消息存储的逻辑。 服务端 只需要修改下rabbitmq的配置即可,在rabbitmq.config中添加ssl_listeners和ssl_options配置项: [ {rabbit,[ {ssl_listeners 的插件,以便自定义插件扩展RabbitMQ功能。

    2.1K80发布于 2018-04-27
领券