activemq訊息中介軟體

2021-08-20 16:24:05 字數 1023 閱讀 3107

生產者：

factory = new connectionfactory("tcp://localhost:61616");


//通過工廠建立連線


using (iconnection connection = factory.createconnection())


}
消費者：

//建立連線工廠


iconnectionfactory factory = new connectionfactory("tcp:");


//通過工廠構建連線


iconnection connection = factory.createconnection();


//這個是連線的客戶端名稱標識


connection.clientid = "firstqueuelistener";


//啟動連線，監聽的話要主動啟動連線


connection.start();


//通過連線建立乙個會話


isession session = connection.createsession();


//通過會話建立乙個消費者，這裡就是queue這種會話型別的監聽引數設定


imessageconsumer consumer = session.createconsumer(new apache.nms.activemq.commands.activemqqueue("firstqueue"), "filter='demo'");


//註冊監聽事件


consumer.listener += new messagelistener(consumer_listener);


connection.stop();


connection.close();
void consumer_listener(imessage message)


", message.text, environment.newline);


}
}

訊息中介軟體ActiveMQ

此處用的是version 5.14.0 windows上安裝非常簡單直雙擊接執行apache activemq 5.14.0 bin win64 activemq.bat檔案 img 出現如圖所示說明執行啟動成功 linux上安裝此處略 然後瀏覽器輸入http localhost 8161 admi...

訊息中介軟體之activeMQ

使用activemq主要有以下幾點，在這裡做一下記錄。1 docker search activemq 2 docker pull webcenter activemq 3 docker images 4 docker run d name activemq p 61617 61616 p 8162...

訊息中介軟體學習1 ActiveMQ

點對點 point to point 專門用於使用佇列queue傳送訊息 基於佇列queue的點對點訊息只能被乙個消費者消費，如多個消費者都註冊到同乙個訊息佇列上，當生產者傳送一條訊息後，而只有其中乙個消費者會接收到該訊息，而不是所有消費者都能接收到該訊息。發布 訂閱 publish subscri...