1. 程式人生 > 實用技巧 >sydnsis 推送和消費amq訊息

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問聲好

部署完畢