前情回顾 前文我们完成了日志采集系统的日志文件监控，配置文件热更新，协程异常检测和保活机制。 本节目标 本节加入kafka消息队列，kafka前文也介绍过了，可以对消息进行排队，解耦合和流量控制的作用，为什么一定要用kafka呢？主要原因就是在日志高并发读取后，如果直接将消息发给前端或者写入数据库， ...
分类：
其他好文 时间：
2019-12-06 17:38:39
阅读次数：
118
一、发送消息到队列（生产者）新建一个maven项目，在pom.xml文件加入以下依赖<dependencies><dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.6.5</vers
分类：
编程语言 时间：
2019-12-06 15:12:16
阅读次数：
78
Java编程思想总结（一）对象导论 1.1 抽象过程 万物皆对象。 程序是对象的集合（即：类），他们通过发送消息(调用方法)来告知彼此要做的。 每个对象都有自己的由其他对象所构成的存储（引用其他对象或基本类型，即组合）。 每个对象都拥有其类型。每个类最重要的区别于其他类的特征就是“可以发送什么样的消 ...
分类：
编程语言 时间：
2019-12-06 00:42:37
阅读次数：
105
Netty学习——Netty和Protobuf的整合 Protobuf作为序列化的工具，将序列化后的数据，通过Netty来进行在网络上的传输 1.将proto文件里的java包的位置修改一下，然后再执行一下protoc 异常捕获：启动服务器端正常，在启动客户端的时候，发送消息，报错 警告: An e ...
分类：
Web程序 时间：
2019-12-03 19:35:00
阅读次数：
143
基于TCP的socket实现 SocketClient.java public class SocketClient { public static void main(String[] args) throws InterruptedException { try { // 和服务器创建连接 So ...
分类：
编程语言 时间：
2019-12-02 16:38:33
阅读次数：
71
prodcer同步发送的机制虽然能保证消息不丢失，但是不推荐生产环境使用，性能很差。一般都是采用异步方式发送消息，把消息先放入缓冲区，然后再由IO线程推送出去，存在消息丢失的风险，而且可能发生乱序。 下面给出Kafka无消息丢失的配置： Producer端配置 block.on.buffer.ful ...
分类：
其他好文 时间：
2019-12-01 23:04:21
阅读次数：
213
对于消息的传递有两种类型： 一种是点对点的，即一个生产者和一个消费者一一对应； 另一种是发布/ 订阅模式，即一个生产者产生消息并进行发送后，可以由多个消费者进 行接收。 特点介绍： 点到点模型点对点传递模型：生产者发送消息到一个特定的队列（Queue）中，而消费者从一个消息队列中得到消息，如下图所示 ...
分类：
其他好文 时间：
2019-11-27 13:51:10
阅读次数：
116
独立消息服务方案 实现思路： 预发送消息：主动方应用系统预发送消息，由消息服务子系统存储消息，如果存储失败，那么也就无法进行业务操作。如果返回存储成功，然后执行业务操作。 执行业务操作：执行业务操作如果成功的时候，将业务操作执行成功的状态发送到消息服务子系统。消息服务子系统修改消息的标识为“可发送” ...
分类：
其他好文 时间：
2019-11-26 13:10:00
阅读次数：
61
RabbitMQ使用以及原理解析 RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue)的开源实现;在RabbitMQ官网上主要有这样的模块信息, Work queues消息队列,Publish/Subscribe发布订阅服务,Routing, Topic ...
分类：
其他好文 时间：
2019-11-24 15:37:03
阅读次数：
84
分布式问题分析 https://www.cnblogs.com/zhang-qc/p/8688052.html 原作者的blog问题写的非常好 先分布式 才能cloud native 参考：https://github.com/CyC2018/Interview-Notebook/blob/mast ...
分类：
其他好文 时间：
2019-11-24 15:20:22
阅读次数：
63
