消息服务 – 蒋智昊的博客

RabbitMQ 3.11 安装

蒋智昊 RabbitMQ / 消息服务 2023年3月20日 2023年3月20日留下评论

1、下载RabbitMQ。rabbitmq-server-3.11.10.exe

RabbitMQ官网下载址：Installing on Windows — RabbitMQ http://www.rabbitmq.com/install-windows.html

2、下载Eralng。otp_win64_25.3.exe

RabbitMQ Erlang 版本要求 https://www.rabbitmq.com/which-erlang.html

Erlang官网下载地址

RocketMQ 5.1 安装

蒋智昊 RocketMQ / 消息服务 2023年3月19日 2023年3月20日留下评论

一、安装

1、下载 rocketmq-all-5.1.0-bin-release.zip 。

地址：https://rocketmq.apache.org/zh/download/

2、解压缩到 D:\java\rocketmq-all-5.1.0-bin-release。

3、设置环境变量。（另外需要安装jdk1.8）

新建 ROCKETMQ_HOME

在PATH里面添加 %ROCKETMQ_HOME%\bin

Nginx开机自动启动

蒋智昊 WebServer / 消息服务 2022年7月19日 2022年7月19日留下评论

1、下载地址 https://github.com/winsw/winsw/releases。选择操作系统匹配的版本，例如WinSW-net461.exe，重命名为 nginx-service.exe。

2、创建配置文件 nginx-service.xml。

<!– nginx-service.xml –>

<id>nginx</id>

<name>nginx</name&g

Linux Kafka集群配置

蒋智昊 Kafka / 消息服务 2022年2月13日 2022年6月9日留下评论

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

# 配置

Resin一个Web服务器

蒋智昊 WebServer 2021年2月4日 2021年2月7日留下评论

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

Nginx一个Web服务器

蒋智昊 WebServer 2021年1月15日 2021年1月17日留下评论

一个高性能的HTTP和反向代理web服务器，同时也提供了IMAP/POP3/SMTP服务。

官网：http://nginx.org/en/download.html

安装：

Docker 安装 Nginx

Jetty一个开源的servlet容器

蒋智昊 WebServer 2021年1月15日 2021年1月16日留下评论

官网：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文件进行修改

Tomcat 9 配置SSL证书基于CentOS系统

蒋智昊 WebServer 2021年1月11日 2021年1月15日留下评论

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

MQTT服务器搭建EMQX基于CentOS系统

蒋智昊 MQTT / 消息服务 2021年1月9日 2022年6月10日留下评论

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

MQTT服务器搭建EMQX

蒋智昊 MQTT / 消息服务 2020年12月24日 2022年6月10日留下评论

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

MQTT客户端Paho实现JavaScript应用

蒋智昊 MQTT / 消息服务 2020年12月23日 2022年6月10日留下评论

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 协议的支持情况如下：

MQTT客户端paho.mqtt-spy

蒋智昊 MQTT / 消息服务 2020年12月23日 2022年6月10日留下评论

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服务器搭建mosquitto和mqttbox

蒋智昊 MQTT / 消息服务 2020年12月17日 2022年6月16日留下评论

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

RabbitMQ一个消息中间件

蒋智昊 RabbitMQ / 消息服务 2020年12月6日 2022年6月9日留下评论

1、官网。https://www.rabbitmq.com/

2、文档。https://www.rabbitmq.com/documentation.html

3、介绍。

RocketMQ一个消息中间件

蒋智昊 RocketMQ / 消息服务 2020年12月6日 2022年6月9日留下评论

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

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

3、介绍。

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

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

Consumer：消息消费的角色，支持分布式集群

Kafka一个分布式流处理平台

蒋智昊 Kafka 2020年12月6日 2022年6月9日留下评论

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

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

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

3、介绍。

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

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

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

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

Kafka适合什么样的场

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

蒋智昊 Cts / WebSocket / WeiXin 2018年11月13日 2018年11月13日留下评论

1、微信小程序前端

// 引入配置文件config

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

var app = getApp();

Page({

/**

* 页面的初始数据

*/

data: {

},

/**

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

*/

onLoad: function(options) {

// 建立连接

wx.connectSocket({

url: ‘ws

关于C# Fleck和Html5实现WebSocket

蒋智昊 C# / Html5 / WebSocket 2018年11月5日 2018年11月5日留下评论

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

关于Java Tomcat和Html5实现WebSocket

蒋智昊 Html5 / Java / WebSocket 2018年11月5日 2018年11月5日留下评论

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.

关于NodeJs和Html5实现WebSocket

蒋智昊 Html5 / NodeJS / WebSocket 2018年11月4日 2018年11月13日留下评论

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