MQ ActiveMQ環境部署 C 推送和接收訊息

2022-09-17 00:48:10 字數 2675 閱讀 2169

一、          activemq環境部署

jdk:jdk-8u91-windows-i586.exe

activemq:apache-activemq-5.15.0,選擇win64,啟動服務activemq,要求埠號61616不被占用,啟動服務效果如圖:

如果安裝提示failed to execute start task,解決方法:停止ics(執行-->services.msc找到internet connection sharing (ics)服務,改成手動啟動或禁用)

activemq類庫:

(1)apache.nms.dll路徑:\apache.nms.activemq-1.7.2-bin\lib\apache.nms\net-3.5

(2)apache.nms.activemq.dll路徑:\apache.nms.activemq-1.7.2-bin\build\net-3.5\debug

二、          c#activemq實現推送接收資料

新增activemq類庫apache.nms.dll、apache.nms.activemq.dll

定義傳值引數類:activemqmodel,命名空間定義:activemqclient。

namespace activemqclient

///

/// 方法名

///

public string method

///

/// 介面引數(t轉json)

///

public string json }}

初始化activemq,註冊推送事件,定義推送方法。

using activemqclient;

using apache.nms;

using apache.nms.util;

using newtonsoft.json;

using system;

using system.collections.generic;

using system.linq;

using system.text;

using system.threading.tasks;

namespace activemq

catch (exception e)

}///

/// 推送activemq

///

///

///

///

public static void send(string guid, object t, string method)

if (session == null)

if (producer == null)

var model = new activemqmodel();

model.guid = guid;

model.method = method;

model.json = jsonconvert.serializeobject(t);

var i = session.createobjectmessage(model);

producer.send(i);

}///

/// 接收activemq訊息

///

///

protected static void onmessage(imessage receivedmsg)}}

}}三、          c#推送activemq,以更新機構商品庫存為例:

推送**:

var model = new

;var guid=guid.newguid().tostring();

var method = "updatestoreproductkuc";

var lst = new list();

lst.add(model);

activemqhelper.send(guid, lst, method);

接收報文格式如下

1activemq站點賬號密碼設定

2activemq的訪問密碼

環境部署 Redis環境部署

目錄 redis環境部署 準備部署目錄 修改配置檔案 啟動服務 檢查 附錄redis常用指令 解壓後目錄基本如下 編譯後在src目錄中可看到編譯產物 可執行的二進位制檔案 主要是這幾個 redis server redis sentinel redis cli redis benchmark red...

LAMP環境部署

lamp環境部署 安裝依賴包 yum install gcc gcc c autoconf libjpeg libjpeg devel libpng libpng devel freetype freetype devel libxml2 libxml2 devel zlib zlib devel ...

docker 環境部署

1 新增docker 安裝源 tee etc yum.repos.d docker.repo eof dockerrepo name docker repository baseurl enabled 1 gpgcheck 1 gpgkey eof2 更新yum軟體庫 yum update 安裝do...