原文:RabbitMQ(三):消息持久化策略一、前言 在正常的服务器运行过程中，时常会面临服务器宕机重启的情况，那么我们的消息此时会如何呢？很不幸的事情就是，我们的消息可能会消失，这肯定不是我们希望见到的结果。所以我们希望AMQP服务器崩溃了也可以将消息恢复，这称之为消息持久化。RabbitMQ自然... ...
分类：
其他好文 时间：
2019-04-12 00:59:06
阅读次数：
207
conn结构主要是存储单个客户端的连接详情信息。每一个客户端连接到Memcached都会有这么一个数据结构。 我们可以看一下conn_new这个方法，在这个方法里面会对iov和msglist两个参数进行初始化。 数据结构关系图（iov和msglist之间的关系）： 从process_get_comm ...
分类：
系统相关 时间：
2019-03-25 10:35:18
阅读次数：
202
声明：本文总结于网络 一、消息中间件介绍 二、消息中间应用场景 三、消息中间件 3.1 常用的消息中间件 3.2 消息中间的消息存储 3.3 消息中间的一致性同步 3.4 消息中间的高可用 四、消息中间件实例项目摘要 ...
分类：
其他好文 时间：
2019-03-17 00:51:50
阅读次数：
150
现在聊一下RabbitMQ消息持久化： 问题及方案描述 1.当有多个消费者同时收取消息，且每个消费者在接收消息的同时，还要处理其它的事情，且会消耗很长的时间。在此过程中可能会出现一些意外，比如消息接收到一半的时候，一个消费者死掉了。 这种情况要使用消息接收确认机制，可以执行上次宕机的消费者没有完成的 ...
分类：
其他好文 时间：
2019-01-13 21:09:55
阅读次数：
309
判断一个数是否是素数 一、判断一个数是否是素数？ java package Java基础; public class TestPrime { public static void main(String[] args) { long startTime1 = System.currentTimeMi ...
分类：
其他好文 时间：
2018-11-29 23:20:47
阅读次数：
193
一、消息队列在实际场景中的使用 流程A在处理时没有在当前线程同步的处理完而是直接发送了一条消息A1到队列里,然后消息队列过了一段时间(可能是几毫秒 几秒 几分钟)这个消息开始被处理,消息处理的过程就相当于流程A被处理;当然这只是一个简单的模型下面我们套用实际的场景来看一下,比如下单成功后发送短信提醒 ...
分类：
其他好文 时间：
2018-11-26 22:04:00
阅读次数：
241
通过三个工程演示整合过程 工程一：API工程：服务端与客户端共同需要引入的工程 pom:无特殊依赖，下边内容供服务端与客户端引用此工程使用 实体类: API: 工程二：生产者工程：服务端 pom dubbo必须依赖项：（使用zk） application.yml：配置dubbo配置项 工程三：消费者 ...
分类：
编程语言 时间：
2018-10-24 22:13:15
阅读次数：
223
一、Kafka消息组织原理 1.磁盘重认识 当需要从磁盘读取数据时，要确定读的数据在哪个磁道，哪个扇区：首先必须找到柱面，即磁头需要移动对准相应磁道，这个过程叫做寻道，所耗费时间叫做寻道时间;然后目标扇区旋转到磁头下,这个过程耗费的时间叫做旋转时间；一次访盘请求（读/写）完成过程由三个动作组成寻道（ ...
分类：
其他好文 时间：
2018-10-10 23:42:11
阅读次数：
240
安装RabbitMQ window下安装: (1)：下载erlang，原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，下载地址：http://www.erlang.org/downloads，双击.exe文件进行安装就好，安装完成之后创建一个名为ERLANG_HOME的环境变量 ...
分类：
编程语言 时间：
2018-08-19 14:49:10
阅读次数：
301
一,kafka是什么？ kafka是一个高吞吐的分布式消息队列系统。二,特点： 是生产者消费者模式，先进先出（FIFO）保证顺序，自己不丢数据，默认每隔7天清理数据。三,消息列队常见场景： 系统之间解耦合、 峰值压力缓冲、 异步通信。四,Spark Streaming + kafka优点： 解耦 缓 ...
分类：
其他好文 时间：
2018-07-22 14:03:26
阅读次数：
154
