activemq简易配置

aec的Python项目详细描述


activemq简易配置

此项目旨在提供一种简单的方法来设置activemq代理网络。你可以很容易地改变拓扑结构 脚本将根据您的设置创建配置。activemq简易配置将为您生成:

  • 每个代理的activemq.xml文件,具有代理的特定配置
  • 每个代理的Docker映像可以在容器编排器中轻松调整。
  • 用于在本地运行Docker映像以便在本地测试网络的脚本。

它是怎么工作的?

让我们以两个activemq代理之间的双工连接为例:


   +----------+                    +----------+
   |          |       Duplex       |          |  
   | Broker 1 | ---<-->----<-->--- | Broker 2 |
   |          |                    |          | 
   +----------+                    +----------+

首先,您必须使用网络的配置定义yaml文件:

brokers:node1:"static:(tcp://node1:61616)"node2:"static:(tcp://node2:61616)"networks:common_configuration:set_broker_name:"false"queue:conduit_subscriptions:"false"consumer_ttl:"1"duplex:"true"message_ttl:"-1"physical_name:">"user_name:"admin"topic:conduit_subscriptions:"true"consumer_ttl:"1"duplex:"true"message_ttl:"-1"physical_name:">"user_name:"admin"network_connector:node1:to:-node2config:queue:duplex:"false"topic:_ignore:"true"node2:to:-node1

yaml中的第一个主题将定义代理和您各自的连接。 如果你想使用Docker,地址可以是代理的名字。

您可以在目录templates中看到许多代理网络的示例。在同一目录中 还有一个activemq.xml文件用作基文件。

创建模板后,您可以运行:

python aec.py \
    --config templates/simple-duplex-config.yaml \
    --activemq templates/activemq.xml \
    --save-to /my/path/project

您将得到以下文件:

  • node1.xml
  • node2.xml

如果您将路径传递给Dockerfile和注册表名,系统将创建:

  • run.sh
  • build.sh
  • 文档文件

您可以运行build.sh来构建Docker映像,运行run.sh来运行本地计算机中的容器。

创建的docker镜像可以很容易地适应在kubernetes、docker swarm或ecs上运行。

在文件夹check中,您可以运行一个简单的生产者/消费者来检查通信。

安装

推荐:

pip install aec

从源获取

只需克隆存储库。

git clone git@github.com:byjg/activemq-easy-config

待办事项

感谢您的帮助:)

  • 此配置可以扩展到activemq上的其他功能。
  • K8S实现
  • Docker Swarm实现
  • ECS实现

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
sql server使用Java读取SQLCMD的输出文件   使用Jackson在没有堆栈跟踪的情况下序列化/反序列化异常   在Java中比较字符串。等于()   数组在Java中显示图像   Java,在对象列表中搜索?   java您需要使用JDK运行build或使用其他工具。类路径上的jar   JavaApacheHTML响应返回乱码   java SQLFunctionTemplate不应用查询参数的顺序   用于跟踪请求工作流的java Guice请求范围   java手柄意图照相机   java Eclipse插件和线程   java列出已运行的jUnit测试   java如何获取与outlook中显示完全相同的pdf格式副本   java从portlet向远程web应用发出HTTP GET请求   如果枚举中的类型只使用一次,我应该创建一个枚举还是一个类   java如何将JSON传递给所需的Web服务   java文件到字节[]的读取不正确   如何解决线程“main”java中的异常。lang.arithmetricexception:/by零?   java在Android活动之间传递字符串