zoukankan      html  css  js  c++  java
  • sydnsis 推送和消费amq消息

    环境是minishift,ubuntu

    1.首先我们要amq上建个账号

    账号会涉及到下面4个文件都在etc目录下

    artemis-roles.properties   broker.xml         login.config
    artemis-users.properties 

    但是这里直接改的账号,下次重启就没有了。

    我用的方法是进pod执行下面的命令创建账号

    进入amq的bin目录

    ./artemis user add --user test --password test --role admin

    2.建queue

    建queue我们使用operator方式

    oc create -f 文件

    文件内容如下

    apiVersion: broker.amq.io/v2alpha2
    kind: ActiveMQArtemisAddress
    metadata:
      name: ex-aaoaddress
    spec:
      addressName: order
      queueName: order
      routingType: anycast

    3.接下来我们进入sydnsis创建接口

    3.1首先我们创建amq连接

    点击create connection

     找到AMQP

     amqp协议,证书检查给禁止调,可以点下面的验证按钮,验证连同性

    接下来点保存就可以

    3.2 创建接口

    接下来我们点integrations

    再点 create integration

    选择timer

     

     选择simple,选1分钟

     再选择 amqp,输入queue名字

    接下来搞 schema,有实力的选择json schema,我选择json实例

    点下一步,看到中间加号没有,点它

     选择data map

     点左边加号,创建一个常量

    接下来作个mapping,就是拉根线,把左边的刚才创建的常量拖到右边

     点下一步,再点发布,输入名字,点保存和发布

     结下里就进入了发布状态,就是在minishift里创建pod

    部署成功之后,我们可以看日志了,以每分钟1个方式向mq写数据

    接下来我们去minishift看看pod问声好

    部署完毕

  • 相关阅读:
    环境变量的配置
    java语言概述
    快捷键,功能键及常用的DOS命令
    html介绍
    Java web学习框架
    线程的使用
    Task类(任务)
    Parallel类(简化Task 操作)
    文件及数据流技术
    泛型的使用
  • 原文地址:https://www.cnblogs.com/caihemm/p/13298105.html
Copyright © 2011-2022 走看看