【solace】基于docker部署solace环境

一、solace

https://www.solace.dev/

solace是一款高性能的消息中间件

 

二、部署脚本

docker run -d \-p 8080:8080 \-p 55555:55555 \-p:8008:8008 \-p:1883:1883 \-p:8000:8000 \-p:5672:5672 \-p:9000:9000 \-p:2222:2222 \--shm-size=2g \--env username_admin_globalaccesslevel=admin \--env username_admin_password=admin \--name=solace \solace/solace-pubsub-standard:lts

 

三、检查

打开http://127.0.0.1:8080/

使用admin /admin登录

 

四、测试

publisher.py

核心代码

topic = Topic.of("solace/try/this/topic") 
messaging_service = MessagingService.builder().from_properties(broker_props).build().connect() 
direct_publisher = messaging_service.create_direct_message_publisher_builder().build().start() 
outbound_msg = messaging_service.message_builder().build("Hello world!") 
direct_publisher.publish(destination=topic, message=outbound_msg)

 

subscribe.py

核心代码

topic = Topic.of("solace/try/>") 
messaging_service = MessagingService.builder().from_properties(broker_props).build().connect() 
direct_receiver = messaging_service.create_direct_message_receiver_builder().with_subscriptions(topic).build().start() 
direct_receiver.receive_async(MessageHandlerImpl())

消息可以正常发送和接收即可

 

也可以使用界面进行测试

 

参考链接：

https://www.cnblogs.com/larrydpk/p/17059116.html

https://www.cnblogs.com/rongfengliang/p/14063645.html