九鹤 九鹤
3年前
RabbitMq 的高级特性
消息可靠性当作为消息的投递着不希望,任何消息投递失败或者消息丢失rabbitmq提供了两种方式来复制投递失败,确保消息的可靠性confirm确认模式return退回模式消息从投递者到product到交换机(exchange)返回一个confirmCallback(不管投递是否成功)都会执行这个回调函数,只是返回的布尔值不一样)exchange到queue
Stella981 Stella981
2年前
RabbitMQ如何通过持久化保证消息99.99%不丢失?
1\.本篇概要要解决该问题,就要用到RabbitMQ中持久化的概念,所谓持久化,就是RabbitMQ会将内存中的数据(Exchange交换器,Queue队列,Message消息)固化到磁盘,以防异常情况发生时,数据丢失。其中,RabblitMQ的持久化分为三个部分:1.交换器(Exchange
Stella981 Stella981
2年前
Dubbo分析之Exchange层
系列文章Dubbo分析Serialize层(https://my.oschina.net/OutOfMemory/blog/2236611)Dubbo分析之Transport层(https://my.oschina.net/OutOfMemory/blog/2251388)Dubbo分析之Exchange层(https
Stella981 Stella981
2年前
RabbitMQ中 exchange、route、queue的关系
从AMQP协议可以看出,MessageQueue、Exchange和Binding构成了AMQP协议的核心,下面我们就围绕这三个主要组件  从应用使用的角度全面的介绍如何利用RabbitMQ构建消息队列以及使用过程中的注意事项。!(https://oscimg.oschina.net/oscnet/d83279dd82e3776a60d9a8c
Stella981 Stella981
2年前
Nebula Exchange 工具 Hive 数据导入的踩坑之旅
!NebulaExchange工具Hive数据导入的踩坑之旅(https://wwwcdn.nebulagraph.com.cn/nebulablog/nebulaexchangehiveimportbestpractice.png)摘要:本文由社区用户xrfinbj贡献,主要介绍Exchange工具从Hive数仓
Stella981 Stella981
2年前
RabbitMQ操作
注意:在rabbitmq中,可以存在多个exchange,exchange只是负责接收消息,然后消息必须发送到给queue中,如果没有queue,消息就丢失了,exchange就相当于交换机,不负责存消息,queue是必须声明的,所以exchange负责转发,queue负责接收!(https://oscimg.oschina.net/oscnet/1
Stella981 Stella981
2年前
RabbitMQ之消息发布订阅与信息持久化技术
信息发布与订阅Rabbit的核心组件包含Queue(消息队列)和Exchanges两部分,Exchange的主要部分就是对信息进行路由,通过将消息队列绑定到Exchange上,则可以实现订阅形式的消息发布及Publish/Subscribe在这种模式下消息发布者只需要将信息发布到相应的Exchange中,而Ex
Stella981 Stella981
2年前
RabbitMQ 基础概念介绍
AMQP消息模型RabbitMQ是基于AMQP(高级消息队列协议)的一个开源实现,其内部实际也是AMQP的基本概念。AMQP的消息发送流程有如下几个步骤:1.消息生产者(producer)将消息发布到Exchange中;2.Exchange根据队列的绑定关系将消息分发到不同的队列(Queue
Stella981 Stella981
2年前
RabbitMQ的五种工作模式的简单实现
1\.不使用Exchange交换机(默认交换机)工具类packagecom.lemon.rabbitmq.utils;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;
Stella981 Stella981
2年前
Exchange 应用1
importjava.util.concurrent.Exchanger;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.TimeUnit;