RocketMQ一个消息中间件

RocketMQ一个消息中间件

1、官网。http://rocketmq.apache.org/

2、文档。https://github.com/apache/rocketmq/tree/master/docs/cn

3、介绍。

RocketMQ架构上主要分为四部分,如上图所示:

Producer:消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。

Consumer:消息消费的角色,支持分布式集群 [阅读全文]

Kafka一个分布式流处理平台

Kafka一个分布式流处理平台

1、官网。http://kafka.apache.org/

2、文档。http://kafka.apache.org/documentation/

https://kafka.apachecn.org/intro.html

3、介绍。

我们知道流处理平台有以下三种特性:

可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。

可以储存流式的记录,并且有较好的容错性。

可以在流式记录产生时就进行处理。

Kafka适合什么样的场 [阅读全文]

关于CTS项目的微信小程序WebSocket开发

关于CTS项目的微信小程序WebSocket开发

1、微信小程序前端

// 引入配置文件config

const urlList = require('../../utils/config.js');

var app = getApp();

Page({

/**

* 页面的初始数据

*/

data: {

},

/**

* 生命周期函数--监听页面加载

*/

onLoad: function(options) {

// 建立连接

wx.connectSocket({

url: 'ws [阅读全文]