一、消息中间件概述 1.1消息中间件产生的背景 在客户端与服务器进行通讯时.客户端调用后，必须等待服务对象完成处理返回结果才能继续执行。 客户与服务器对象的生命周期紧密耦合,客户进程和服务对象进程都都必须正常运行;如果由于服务对象崩溃或者网络故障导致用户的请求不可达,客户会受到异常 点对点通信: 客 ...
分类：
其他好文 时间：
2019-06-09 18:20:47
阅读次数：
105
在上一篇《ActiveMQ入门系列二：入门代码实例（点对点模式）》中提到了ActiveMQ中的两种模式：点对点模式（PTP）和发布/订阅模式（Pub & Sub），详细介绍了点对点模式并用代码实例进行说明，今天就介绍下发布/订阅模式。 一、理论基础 发布/订阅模式的工作示意图： 消息生产者将消息（发 ...
分类：
其他好文 时间：
2019-06-08 14:43:02
阅读次数：
98
接到的项目是：spring的项目做spring整合rabbitMQ的作生产者，而测试使用springboot整合RmQ做消费者，交换机模式 Topic,这里还涉及到队列和消息的持久化,这里稍作总结！ spring整合rabbitMQ的作生产者： pom.xml: rabbitMq.xml aappl ...
分类：
其他好文 时间：
2019-06-05 16:29:37
阅读次数：
102
生产者消费者的问题及其解决办法 问题 在之前的生产者消费者模型中，生产者和消费者只有一个， 那么生产者往队列里put几次，消费者就get几次，但是存在一个问题， 生产者不一定只有一个，消费者也不一定只有一个，那么怎么确定生产者进程结束了， 从而让消费者进程跟着一起结束成为一个问题（不然消费者还是一直 ...
分类：
编程语言 时间：
2019-06-04 22:49:24
阅读次数：
250
复习1.守护进程2.互斥锁（解决数据错乱的方法）3.IPC（进程间通讯）4.生产者与消费者模型详解：1.守护进程 一个进程可以设为另一个进程的守护进程 特点：被守护的进程结束时，守护进程也会随之结束 本质：父进程交给子进程一个任务，然而父进程 先于子进程结束了，子进程的任务也就没有必要 继续执行了 ...
分类：
编程语言 时间：
2019-06-04 16:14:37
阅读次数：
157
demo1 单生产者多消费者创建。 maven 依赖 1 对象 - Message 2 在主函数中创建 disruptor 3 disruptor 绑定消费者 4 启动 disruptor 5 disruptor 绑定生产者 6 阻塞等待 & 关闭服务 ...
分类：
其他好文 时间：
2019-06-04 09:43:29
阅读次数：
141
一：Kafka概述 离线部分： Hadoop->离线计算(hdfs / mapreduce) yarn zookeeper->分布式协调（动物管理员） hive->数据仓库（离线计算 / sql）easy coding flume->数据采集 sqoop->数据迁移mysql->hdfs/hive ...
分类：
其他好文 时间：
2019-06-04 09:20:50
阅读次数：
124
守护进程 进程：一个正在运行的程序。 主进程创建守护进程： 1.守护进程会在主进程代码执行结束后就终止， 2.守护进程内无法再开启子进程,否则抛出异常。 注意：进程之间是互相独立的，主进程代码运行结束，守护进程随即终止。 例子：from multiprocessing import Processi ...
分类：
系统相关 时间：
2019-06-03 22:05:09
阅读次数：
164
1.本篇概要RabbitMQ针对这个问题，提供了以下几个机制来解决：生产者确认持久化手动Ack本篇博客我们先讲解下生产者确认机制，剩余的机制后续单独写博客进行讲解。2.生产者确认要想保证消息不丢失，首先我们得保证生产者能成功的将消息发送到RabbitMQ服务器。但在之前的示例中，当生产者将消息发送出去之后，消息到底有没有正确地到达服务器呢？如果不进行特殊配置，默认情况下发送消息的操作是不会返回任何
分类：
其他好文 时间：
2019-06-03 17:09:56
阅读次数：
78
Kafka session.timeout.ms heartbeat.interval.ms参数的区别以及对数据存储的一些思考 在计算机世界中经常需要与数据打交道，这也是我们戏称CURD工程师的原因之一。写了两年代码，接触了不少存储系统，Redis、MySQL、Kafka、Elasticsearch ...
分类：
其他好文 时间：
2019-06-01 23:08:23
阅读次数：
367
