1.kafka架构 kafka处理消息大概流程 + 生产者发送消息给kafka服务器 + 消费者从kafka服务器（broker）读取消息 + kafka服务器依靠zookeeper集群进行服务协调管理 2.kafka基本术语 + message （消息） 生产消费的基本单位。 + topic（主题 ...
分类：
其他好文 时间：
2019-09-06 01:45:41
阅读次数：
121
文章目录 1. 什么是幂等性？1.1 消息队列的幂等性1.2 模拟重试机制1.2.1 生产者代码1.2.2 消费者代码1.2.3 消费者 application.yml 配置2. 如何保证消息幂等性，不被重复消费？解决方法 1. 什么是幂等性？ 在编程中一个幂等操作的特点是其任意多次执行所产生的影响 ...
分类：
其他好文 时间：
2019-09-05 00:39:06
阅读次数：
139
介绍 阻塞队列（BlockingQueue）是指当队列满时，队列会阻塞插入元素的线程，直到队列不满；当队列空时，队列会阻塞获得元素的线程，直到队列变非空。阻塞队列就是生产者用来存放元素、消费者用来获取元素的容器。 当线程 插入/获取 动作由于队列 满/空 阻塞后，队列也提供了一些机制去处理，或抛出异 ...
分类：
编程语言 时间：
2019-09-04 10:05:24
阅读次数：
79
TCP 协议下的 socket 通信 TCP UDP 的区别 三次握手 四次挥手 七层协议 粘包 (方案) 什么是进程 , 什么是线程 二者的区别 阻塞 和非阻塞 守护进程和守护线程的区别 GIL 锁(重点) 为什么在有 GIL 锁的情况下,还要使用普通锁 SQL 语句 事务四大特性 pymysql ...
分类：
数据库 时间：
2019-09-03 22:34:28
阅读次数：
147
1.pom文件引入Kafka依赖（我用的版本是2.2.2.RELEASE） 2.编写Kafka sender工具类 3.在需要发送消息的地方，调用KafkaSender的send方法 测试一下： ...
分类：
其他好文 时间：
2019-09-03 14:58:28
阅读次数：
104
RabbitMQ能做啥 场景一：支付的通知 生产者：微信支付完成之后在其回调方法中调用一个服务接收消息，这个服务作为生产者。 消费者：消费者服务是一个不断从队列中获取支付结果的应用，然后在app或者页面展示。 场景二：注册的短信或者邮件通知 生产者：注册成功之后的回调中，发送注册成功信息到队列生产者 ...
分类：
其他好文 时间：
2019-09-03 09:27:49
阅读次数：
81
1.生产者： 生产者发送消息到broker，有三种确认方式（request.required.acks）acks = 0: producer不会等待broker（leader）发送ack 。因为发送消息网络超时或broker crash(1.Partition的Leader还没有commit消息 2 ...
分类：
其他好文 时间：
2019-09-03 00:10:47
阅读次数：
141
阻塞式队列在多线程应用中比较常见，比如做为 生产者，消费者 共享队列。 常见流程如下： c# 提供阻塞队列如： BlockingCollection ，了解原理后，自个写了一个队列: ...
分类：
其他好文 时间：
2019-09-02 19:27:56
阅读次数：
73
问题导读 1.如何启动kafka？ 2.如何通过代码实现生产者例子 ？ 3.如何通过代码实现消费者例子 ？ 1.启动kafka。 //启动zookeeper server (用&是为了能退出命令行)： bin/zookeeper-server-start.sh config/zookeeper.pr ...
分类：
其他好文 时间：
2019-09-02 11:43:06
阅读次数：
74
多线程 同步对象 解决什么问题？ 想要指定的一个线程先执行，再去执行其他线程 精华如下 信号量 相当于一次可以多个线程的同步锁 输出结果：一次打印5个线程的输出 Thread 1 Thread 4 Thread 2 Thread 3 Thread 5 Thread 6 Thread 9 Thread ...
分类：
其他好文 时间：
2019-09-01 21:59:58
阅读次数：
101
