同步：发送一个请求，等待返回，然后再发送下一个请求 异步：发送一个请求,不等待返回,随时可以再发送下一个请求 使用场景 如果数据存在线程间的共享，或竞态条件，需要同步。如多个线程同时对同一个变量进行读和写的操作 当应用程序在对象上调用了一个需要花费很长时间来执行的方法，并且不希望让程序等待方法的返回 ...
分类：
其他好文 时间：
2019-12-17 15:08:48
阅读次数：
77
kafka 由于它自身的高性能发送与消费能力，而受到广大企业的喜欢，所以我们就先看看kafka 一些源码实现如下： 这段代码摘抄的是，kafka源码 生产者发送消息demo（kafka.examples.Producer） 里面的一个片段，主要是涉及到两个知识点，一个是异步发送消息， 回调函数的实现 ...
分类：
其他好文 时间：
2019-11-22 23:24:35
阅读次数：
79
安装 Config.py 新建py文件send_mail.py：然后新建一个类BaseMail 继承Flask Mail的 Mail app.py:这时初始化Mail的时候直接用继承后的BaseMail view中使用：直接import app.py中的mail进行发送，使用mail.async_s ...
分类：
其他好文 时间：
2019-10-26 15:36:33
阅读次数：
99
在sendDefaultImpl方法里面： 如果是同步的话，必须发送成功，还必须返回是ok才认为成功，否则继续重试。 如果是oneway、异步的话，直接return null出去了，那么异步如何做重试? 上面代码最核心的发送函数就是sendKernelImpl 可以看到，对于异步模式和非异步模式，s ...
分类：
其他好文 时间：
2019-10-01 22:28:39
阅读次数：
309
消息队列高可用 ，`事务 签收 zookeeper+replicated leveldb store`的主从集群 异步发送 同步发送： 1. 明确指定同步发送 2. 未使用事务的前提下，发送持久化消息（会使用同步发送，且会阻塞producer直到broker返回一个确认，表示消息已持久化。会阻塞客户 ...
分类：
其他好文 时间：
2019-08-25 17:51:06
阅读次数：
108
https://my.oschina.net/u/1859679/blog/1844109 该模式可以有简单实现、也可以多线程实现、要看场景，比喻redis的实现就是简单，因为都是基于内存操作。 学习下！ 基于Reactor Pattern 处理模式中，定义以下三种角色: Reactor 将I/O事 ...
分类：
编程语言 时间：
2019-08-10 14:20:41
阅读次数：
135
通过提示说明Celery 4.x 需要Django1.11或者后面的版本，可是使用的是django1.8.2的版本，最先以为是自己什么地方配置出错了，找了很久也没有找到。 任务队列启动没错，任务处理启动也没问题，打开输入地址就报错。 最终看到使用的是Celery4.3.0，然后改成4.1.0版本就可 ...
分类：
其他好文 时间：
2019-07-31 23:46:20
阅读次数：
100
本篇博文是“Java秒杀系统实战系列文章”的第八篇，在这篇文章中我们将整合消息中间件RabbitMQ，包括添加依赖、加入配置信息以及自定义注入相关操作组件，比如RabbitTemplate等等，最终初步实现消息的发送和接收，并在下一篇章将其与邮件服务整合，实现“用户秒杀成功发送邮件通知消息”的功能！ ...
分类：
编程语言 时间：
2019-07-26 10:46:53
阅读次数：
139
python 发送kafka大体有三种方式 1 发送并忘记（不关注是否正常到达，不对返回结果做处理） 2 同步发送(通过get方法等待Kafka的响应，判断消息是否发送成功) 3 异步发送+回调函数(消息以异步的方式发送，通过回调函数返回消息发送成功/失败) 除此之外，还能发送压缩数据流 ...
分类：
编程语言 时间：
2019-07-23 17:06:13
阅读次数：
166
一、消息游标二、异步发送三、严格分发策略四、轮询分发策略五、优化批量确认六、生产者流量控制
分类：
其他好文 时间：
2019-07-01 00:31:02
阅读次数：
91
