企业信息化建设
1、解压缩。创建软连接。
tar kafka_2.12-1.1.1.tgz
ln -s kafka_2.12-1.1.1 kafka
2、修改Kafka配置文件。
（1）zookeeper.properties
# 指定Zookeeper 数据目录
dataDir=/home/hadoop/data/zookeeper/zkdata
# 指定Zookeeper 端口号
clientPort=2181
（2）consumer.properties
# 配置 [阅读全文]
1、官网。http://rocketmq.apache.org/
2、文档。https://github.com/apache/rocketmq/tree/master/docs/cn
3、介绍。
RocketMQ架构上主要分为四部分，如上图所示:
Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。
Consumer：消息消费的角色，支持分布式集群 [阅读全文]
1、官网。http://kafka.apache.org/
2、文档。http://kafka.apache.org/documentation/
https://kafka.apachecn.org/intro.html
3、介绍。
我们知道流处理平台有以下三种特性：
可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。
可以储存流式的记录，并且有较好的容错性。
可以在流式记录产生时就进行处理。
Kafka适合什么样的场 [阅读全文]
1、微信小程序前端
// 引入配置文件config
const urlList = require('../../utils/config.js');
var app = getApp();
Page({
/**
* 页面的初始数据
*/
data: {
},
/**
* 生命周期函数--监听页面加载
*/
onLoad: function(options) {
// 建立连接
wx.connectSocket({
url: 'ws [阅读全文]
1、下载Fleck。
https://github.com/statianzo/Fleck
2、把Fleck拖入项目工程。
3、测试代码。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Fleck;
namespace fleck
{
class [阅读全文]
1、Java8+Tomcat8。
package com.ssm.cts.websocket;
import javax.websocket.CloseReason;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket. [阅读全文]
1、下载Node.js，安装node-v10.13.0-x64.msi。
https://nodejs.org/en/
2、安装ws模块。
在cmd命令中输入：npm install nodejs-websocket
3、编写一个server.js文件。
var ws = require("nodejs-websocket")
//
var server = ws.createServer(function (conn) {
console.log("New co [阅读全文]
Python、Html5、WebSocket的例子。
1、服务端websocket.py
#coding=utf8
import struct, socket, sys
import hashlib
import threading, random
import time
from base64 import b64encode, b64decode
connectionlist = {}
def decode(data):
if not len(data [阅读全文]
1、下载MINA 2.0.19 released。
http://mina.apache.org/mina-project/index.html
2、常见问题：
（1）、spring版本差异导致的问题（spring2.5迁移至spring4）
<bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
<property name="customEditors" [阅读全文]
