Nginx开机自动启动
1、下载地址 https://github.com/winsw/winsw/releases。选择操作系统匹配的版本,例如WinSW-net461.exe,重命名为 nginx-service.exe。
2、创建配置文件 nginx-service.xml。
<!– nginx-service.xml –>
<service>
<id>nginx</id>
<name>nginx</name&g
1、下载地址 https://github.com/winsw/winsw/releases。选择操作系统匹配的版本,例如WinSW-net461.exe,重命名为 nginx-service.exe。
2、创建配置文件 nginx-service.xml。
<!– nginx-service.xml –>
<service>
<id>nginx</id>
<name>nginx</name&g
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、官网。https://caucho.com
2、下载。ttps://caucho.com/products/resin/download
3、下载zip版本。打开resin.exe启动web服务。resin.exe提供了启停选项。
4、访问http://localhost:8080,出现resin的主页,显示Resin® Default Home Page。
点击/resin-admin 设置账号密码。
单击 Create Con
一个高性能的HTTP和反向代理web服务器,同时也提供了IMAP/POP3/SMTP服务。
官网:http://nginx.org/en/download.html
安装:
官网:https://www.eclipse.org/jetty/
Jetty是一个提供HHTP服务器、HTTP客户端和javax.servlet容器的开源项目。
1、目录描述。webapps:一个用来存放运行在默认配置下的Jetty Web应用目录。
2、启动:进入cmd命令行。
java -jar start.jar
3、jetty默认端口是8080。
a、jetty-home-11.0.0版本:可以编辑jetty-http.xml文件进行修改
1、下载最新版本Tomcat9。https://tomcat.apache.org/
unzip apache-tomcat-9.0.41.zip
2、启动./startup.sh
如果出现权限不足,则需要授予权限。
chmod u+x *.sh
chmod是权限管理命令change the permissions mode of a file的缩写。
u代表所有者,x代表执行权限。 + 表示增加权限。
chmod u+x file.sh 就表示对当前目录下的f
1、下载 https://www.emqx.io/cn/downloads#broker
查看centos版本的方法:
(1)、在centos桌面右键“打开终端”。或者用WinSCP客户端。
(2)、接着会弹出终端窗口。
(3)、在里面输入“cat /etc/redhat-release”命令。
(4)、回车后就可以输出centos系统的版本。
(5)、使用“uname -a”命令可以查看内核版本等信息。
2、解压缩 unzip emqx-centos7-4.2
1、下载 https://www.emqx.io/cn/downloads#broker
2、解压缩emqx-windows-4.2.3.zip,解压到c盘。
3、cmd命令行下进入解压路径,启动 emqx。
emqx start
EMQ X 提供了 emqx 命令行工具,方便用户对 EMQ X 进行启动、关闭、进入控制台等操作。
emqx start后台启动 EMQ X Broker;
emqx stop关闭 EMQ X Broker;
emqx
Eclipse Paho 项目提供了 MQTT 消息传递协议的开源客户端实现,官网如下
https://www.eclipse.org/paho/
Eclipse paho 项目提供了如下语言的库:
Java
Python
JavaScript
GoLang
C
C++
Rust
Net (C#)
Android Service
Embedded C/C++
针对这些语言的提供的 MQTT 客户端库目前对 MQTT 协议的支持情况如下:
1、下载。下载地址:https://github.com/eclipse/paho.mqtt-spy/releases。
下载包含依赖包的版本:mqtt-spy-1.0.1-beta-b18-jar-with-dependencies.jar。
2、cmd进入命令行。(需要配置jdk环境http://chanpinxue.cn/archives/2816.html)
3、配置连接。
4、消息发布、订阅。
MQTT(Message Queuing Telemetry Transport):消息队列遥测传输。
一、在Windows搭建mosquitto服务器
1、下载地址:https://mosquitto.org/download/。最新版本是mosquitto-2.0.0。mosquitto-2.0.2-install-windows-x64.exe。
2、安装路径 C:\mosquitto。
mosquitto.conf:mosquitto服务器的配置文件。
mosq
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”