我已经有了一个SimpleBrokerWebsocket实现.现在我正在迁移到基于微服务的架构,并尝试将消息传递作为单独的微服务.
为了避免破坏现有的客户端部署并逐步转向完整的基于微服务的架构,我希望我的旧套接字端点重定向到微服务提供的新套接字端点.
所以我需要一些想法,如何处理身份验证和向正确的用户发送消息.
此外,我想知道如何为这个要求的架构.我想使用StompBrokerRelay进行微服务.
我使用docker compose成功设置了Rabbitmq集群,以了解集群概念。下面是docker compose文件,它工作正常:
rabbit1:
image: ipf-queue-node
hostname: rabbit1
cap_add:
- ALL
- NET_ADMIN
- SYS_ADMIN
ports:
- "5671:5671"
- "5672:5672"
- "15672:15672"
rabbit2:
image: ipf-queue-node
hostname: rabbit2
cap_add:
- ALL
- NET_ADMIN
- SYS_ADMIN
links:
- rabbit1
environment:
- CLUSTERED=true
- CLUSTER_WITH=rabbit1
- RAM_NODE=true
ports:
- "5675:5671"
- "5673:5672"
- "15673:15672"
Run Code Online (Sandbox Code Playgroud)
Docker文件内容:
FROM queue-base
# Create directories
RUN mkdir /opt/rabbit
RUN mkdir /opt/simulator
RUN mkdir /opt/simulator/tools
# Add the files from the local repository into the container
ADD rabbitmq.config /etc/rabbitmq/ …Run Code Online (Sandbox Code Playgroud)