案例一 rewrite_by_lua ' --引入openresty自带的json处理对象 local cjson = require("cjson") local producer = require "resty.kafka.producer" -- 定义kafka broker地址，ip需要和 ...
分类：
其他好文 时间：
2019-03-26 18:20:53
阅读次数：
553
Redis简介 Redis is an open source (BSD licensed), in memory data structure store, used as a database, cache and message broker. It supports ...
分类：
其他好文 时间：
2019-03-22 17:01:40
阅读次数：
108
1. MQTT 介绍它是一种 机器之间通讯 machine-to-machine (M2M)、物联网 Internet of Things （IoT）常用的一种轻量级消息传输协议适用于网络带宽较低的场合包含发布、订阅模式，通过一个代理服务器（broker），任何一个客户端（client）都可以订阅或 ...
分类：
其他好文 时间：
2019-03-20 17:38:28
阅读次数：
232
环境：Ubuntu 16.04 一. MQTTMQTT 是一个轻量级即时通信协议，使用基于 TCP/IP 协议的发布/订阅消息转发模式， MQTT 协议的中心是 broker（ 服务器/代理），客户端通过订阅消息和发布消息进行数据交互。 若初次接触MQTT协议，可先理解以下概念： 【MQTT协议特点 ...
分类：
系统相关 时间：
2019-03-18 13:20:22
阅读次数：
446
What is RocketMQ Apache RocketMQ是一个分布式消息传递和流平台，具有低延迟，高性能和可靠性，万亿级容量和灵活的可扩展性。 它由四部分组成：NamerServer，Broker，Produer和Customer。 它们中的每一个都可以水平扩展而没有单一的故障点。 如下面的 ...
分类：
其他好文 时间：
2019-03-18 01:02:25
阅读次数：
222
1.大纲 Kafka控制节点用的是什么？ 消费者、生产者是如何理解的？ 2.Kafka控制节点用的是什么？ 基于zookeeper协调的分布式消息系统 3.消费者、生产者是如何理解的？ 消息系统通常都会由生产者，消费者，Broker三大部分组成，生产者会将消息写入到Broker，消费者会从Broke ...
分类：
其他好文 时间：
2019-03-14 00:43:16
阅读次数：
188
1 下载地址 http://www.kafkatool.com/download.html 2 下载dmg包，选择对应版本，我的kafka是2.1的版本，所以选择了Kafka Tool 2.0.4 3 安装过程，一路下一步 4 配置kafka集群，注意本机的hostname配置，根据个人机器情况配置 ...
分类：
系统相关 时间：
2019-03-12 10:36:00
阅读次数：
1061
简单的介绍下基于JMS的消息传送 Java消息队列JMS整体设计结构 基本要素：生产者(producer)，消费者(consumere)，消息服务(broker) 交互模型： JMS两种消息传送模式 点对点(Point-to-Point)：专门用于使用队列Queue传送消息； 发布/订阅(Publi ...
分类：
其他好文 时间：
2019-03-06 19:14:49
阅读次数：
157
摘自：https://www.cnblogs.com/qingyunzong/p/9004703.html 一、高可用的由来 1.1 为何需要Replication 在Kafka在0.8以前的版本中，是没有Replication的，一旦某一个Broker宕机，则其上所有的Partition数据都不可 ...
分类：
其他好文 时间：
2019-03-05 23:03:14
阅读次数：
225
数据库分离(备份)后，附加(还原)回到数据库，然后在程序中打开调用数据库的页面，出现如下问题：“未启用当前数据库的 SQL Server Service Broker，因此查询通知不受支持。如果希望使用通知，请为此数据库启用 Service Broker ”。 解决方案：（可直接执行第二步）在使用的 ...
分类：
数据库 时间：
2019-03-05 18:24:32
阅读次数：
200
