一：消费者确认 消费者确认或者说消费者应答指的是RabbitMQ需要确认消息到底有没有被收到 - 自动应答 在订阅消息的时候可以指定应答模式,当自动应答等于true的时候，表示当消费者一收到消息就表示消费者收到了消息，消费者收到了消息就会立即从队列中删除。 生产者 消费者 运行结果： 运行生产者可以 ...
分类：
其他好文 时间：
2018-09-04 11:36:38
阅读次数：
202
Python提供的Condition对象提供了对复杂线程同步问题的支持。Condition被称为条件变量，除了提供与Lock类似的acquire和release方法外，还提供了wait和notify方法。线程首先acquire一个条件变量，然后判断一些条件。如果条件不满足则wait；如果条件满足，进 ...
分类：
其他好文 时间：
2018-09-03 15:34:03
阅读次数：
166
何为阻塞队列，其与普通队列有何差别？ 总的来说，就是能够在适当的时候阻塞"存"和"取"两个操作，以达到控制任务流程的效果。阻塞队列提供了可阻塞的put和take方法。如果队列已经满了，那么put方法将阻塞直到有空间可用；如果队列为空，那么take方法将会阻塞直到有元素可用。 阻塞队列接口及实现来自于 ...
分类：
其他好文 时间：
2018-09-03 13:52:51
阅读次数：
176
springCloud Spring Boot mybatis分布式微服务云架构-docker-feign-hystrix-ribbon（七） 通过在配置文件application.yml配置，开启ribbon,并指定调用生产者相对上一节可以不做任何更改，可以看项目（microservice-con... ...
分类：
编程语言 时间：
2018-09-03 12:11:59
阅读次数：
189
微服务springCloud-docker-feign-hystrix（六） 上一节我们讨论feign的配置，这节我们讨论一下，feign+hystrix调用生产者时，进行容错处理 完整项目的源码来源 技术支持 2147775633 ...
分类：
编程语言 时间：
2018-09-03 12:05:29
阅读次数：
160
在线程安全解决之后，还是一样存在着如下的问题： A：如果消费者先抢到CPU的执行权，就会去消费数据，但是现在的数据是默认值，没有意义，应该等着数据有意义，再消费。 B：如果生产者先抢到CPU的执行权，就会去生产数据，但是呢，它生产完数据后，还继续拥有执行权，它又继续产生数据。这是有问题的，它应该等着 ...
分类：
编程语言 时间：
2018-09-02 20:31:54
阅读次数：
164
一、摘要 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： 1、消息的顺序问题 2、消息的重复问题 二、关键特性以及其实现原理 2.1、顺序消息 要实现严格的顺序消息，简单且可行的办法就是： 保证生产者 - MQS ...
分类：
其他好文 时间：
2018-09-02 13:17:00
阅读次数：
418
1 面试题：Dubbo中zookeeper做注册中心，如果注册中心集群都挂掉，发布者和订阅者之间还能通信么？ 可以的，启动dubbo时，消费者会从zk拉取注册的生产者的地址接口等数据，缓存在本地。每次调用时，按照本地存储的地址进行调用 注册中心对等集群，任意一台宕掉后，会自动切换到另一台 注册中心全 ...
分类：
其他好文 时间：
2018-08-31 10:45:02
阅读次数：
164
1 RabbitMQ知识点 1.1 整体架构图 消息生产者将消息投递到exchange中，exchange会以某种路由机制将生产者投递的消息路由到queue中，消息消费者再从queue中获取消息进行消费。 1.2 核心概念 1.2.1 server 又称Broker，接收客户端的连接，实现AMQP实 ...
分类：
编程语言 时间：
2018-08-31 00:33:33
阅读次数：
313
EOS每年增发1%的机制在系统合约中，其实说每年增发1%只是一年的总数，其实是只要在出块，EOS就在增发的路途中，下面分析一下增发的代码。 其实增发的1%的都是分给所有区块生产者的，只要出块了或者获得投票都有奖励，代码在producer_pay.cpp文件中，只有下面两个函数。 这个onlock函数 ...
分类：
其他好文 时间：
2018-08-30 16:46:28
阅读次数：
287
