RPC：Remote Produce Call远程过程调用 类似的还有RMI。自定义数据格式，基于原生TCP通信，速度快，效率高。早期的webservice，现在热门的dubbo，都是RPC的典型. 该协议允许运行于一台计算机的程序调用另一台计算机的子程序，而程序员无需额外地为这个交互作用编程。说得 ...
分类：
其他好文 时间：
2018-12-27 03:09:50
阅读次数：
159
前题 dubbox是dubbo的一个升级版，简单说就是本来dubbo是阿里开发的，现在阿里不维护了，当当网拿过去继续开发。本来阿里的dubbo维护到2.6版本，而再高版本的都是当当网维护的就叫成dubbox了。 dubbo的机制是这样的，首先有一个数据中心zookeeper,这里zookeeper的 ...
分类：
编程语言 时间：
2018-12-26 17:52:12
阅读次数：
176
一、RabbitMQ：降低主程序线程压力,是一种非阻塞模式的分布式消息队列服务器，由生产者生产到RabbitMQ，消费者消费 二、入门小Demo 1、首先引入rabbitMQ jar包 2、生产者代码： 注1：queueDeclare第一个参数表示队列名称、第二个参数为是否持久化（true表示是，队 ...
分类：
其他好文 时间：
2018-12-25 21:11:11
阅读次数：
133
[TOC] 为了持久化保存容器的数据，可以使用 Kubernetes Volume。 Volume 的生命周期独立于容器，Pod 中的容器可能被销毁和重建，但 Volume 会被保留。 本质上，Kubernetes Volume 是一个目录，这一点与 Docker Volume 类似。当 Volum ...
分类：
Web程序 时间：
2018-12-22 01:05:20
阅读次数：
282
一. kibana安装 1.到官网或是用brew下载kibana 安装包，这边我们选择在官网下载对应的安装包 https://www.elastic.co/cn/downloads/kibana 2.解压缩到对应的目录下，我们解压缩到了 /usr/local/kibana-6.5.2-darwin- ...
分类：
其他好文 时间：
2018-12-20 14:17:13
阅读次数：
400
一、需求场景 exactly once 消息重复一直是消息领域的一个痛点，而消息重复可能发生于下面这些场景 1.消息发送端发出消息，服务端落盘以后因为网络等种种原因发送端得到一个发送失败的响应，然后发送端重发消息导致消息重复。 2.消息消费端在消费过程中挂掉另一个消费端启动拿之前记录的位点开始消费， ...
分类：
其他好文 时间：
2018-12-15 21:09:05
阅读次数：
145
Java实现生产者消费者的方式有：wait && notify、BlockingQueue、Lock && Condition等 wait、notify注意事项：(1)可以使用wait（）和notify（）方法在Java中实现线程间通信。不只是一个或两个线程，而是多个线程可以使用这些方法相互通信。( ...
分类：
其他好文 时间：
2018-12-15 17:24:19
阅读次数：
201
广播模式：1对多，produce发送一则消息多个consumer同时收到。注意：广播是实时的，produce只负责发出去，不会管对端是否收到，若发送的时刻没有对端接收，那消息就没了，因此在广播模式下设置消息持久化是无效的。 三种广播模式： fanout: 所有bind到此exchange的queue ...
分类：
其他好文 时间：
2018-12-13 19:30:40
阅读次数：
485
import asyncio from threading import Thread import time t=time.time() async def inspect(i): print('parse', i, time.time()-t) async def produce(i,sem):... ...
分类：
其他好文 时间：
2018-12-13 16:32:26
阅读次数：
271
ActiveMQ简介 MQ是消息中间件，是一种在分布式系统中应用程序借以传递消息的媒介，常用的有ActiveMQ，RabbitMQ，kafka。ActiveMQ是Apache下的开源项目，完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。消息类型包括点对点（queue），一对多 ...
分类：
其他好文 时间：
2018-12-13 16:25:27
阅读次数：
268
