RocketMQ

RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件,前身是MetaQ,是阿里参考Kafka特点研发的一个队列模型的消息中间件,后开源给apache基金会成为了apache的顶级开源项目,具有高性能、高可靠、高实时、分布式特点。

阅读更多

在Windows下安装使用Kafka

1
2
3
4
5
6
cd xxxx\kafka\bin\windows

# start zookeeper
.\zookeeper-server-start.bat ..\..\config\zookeeper.properties
# start kafka
.\kafka-server-start.bat ..\..\config\server.properties
阅读更多

在 CentOS 上安装 Docker 引擎

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
# Uninstall old versions
sudo yum remove docker \
docker-client \
docker-client-latest \
docker-common \
docker-latest \
docker-latest-logrotate \
docker-logrotate \
docker-engine


# Install Docker Engine
sudo yum install -y yum-utils

sudo yum-config-manager \
--add-repo \
https://download.docker.com/linux/centos/docker-ce.repo

sudo yum install docker-ce docker-ce-cli containerd.io -y

# Start Docker.
sudo systemctl start docker

## 设置docker开机启动
systemctl enable docker

# Verify that Docker Engine is installed correctly by running the hello-world image.
sudo docker run hello-world

阅读更多

在 wsl ubuntu 18.04 上安装 Docker 引擎

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
# Uninstall old versions
sudo apt-get remove docker docker-engine docker.io containerd runc
#Set up the repository
#Update the apt package index and install packages to allow apt to use a repository over HTTPS:

sudo apt-get update -y
sudo apt-get install \
ca-certificates \
curl \
gnupg \
lsb-release


curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /usr/share/keyrings/docker-archive-keyring.gpg


echo \
"deb [arch=$(dpkg --print-architecture) signed-by=/usr/share/keyrings/docker-archive-keyring.gpg] https://download.docker.com/linux/ubuntu \
$(lsb_release -cs) stable" | sudo tee /etc/apt/sources.list.d/docker.list > /dev/null

sudo apt-get update -y
sudo apt-get install docker-ce docker-ce-cli containerd.io

service docker start
sudo systemctl enable docker

sudo docker run hello-world
阅读更多

connection_closed_before_response

reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:

阅读更多