string s = ""; //傳送的資訊
connectionfactory factory = new connectionfactory();
// 設定接入點，到控制台概覽頁面上檢視獲取
factory.sethost("aliyuncs.com");
// $ 為資源 owner 賬戶 id 資訊，單擊控制台右上角客戶頭像進入賬號管理檢視
// $ 阿里雲身份驗證，在阿里雲伺服器管理控制台建立
// $ 阿里雲身份驗證，在阿里雲伺服器管理控制台建立
//一定要這個才能自動恢復
factory.setcredentialsprovider(new aliyuncredentialsprovider($, $, $));
factory.setautomaticrecoveryenabled(true);
factory.setnetworkrecoveryinterval(5000);
// 設定 vhost 名稱，請確保已在控制台上建立完成
factory.setvirtualhost("vhostname");
// 預設埠，非加密埠 5672，加密埠 5671
factory.setport(5672);
//基於網路環境合理設定超時時間
factory.setconnectiontimeout(30 * 1000);
factory.sethandshaketimeout(30 * 1000);
factory.setshutdowntimeout(0);
connection connection = factory.newconnection();
channel channel = connection.createchannel();
//設定exchangetype
channel.exchangedeclare("ex_live_msg", "fanout",true,false,null);
// 開始傳送訊息
// $ 必須在控制台上已存在，並且 exchange 的型別與控制台上的型別一致
// bindingkey 根據業務需求填入相應的 bindingkey
channel.basicpublish("ex_live_msg", "down", true, null,
s.getbytes(standardcharsets.utf_8));
connection.close();
string s = ""; //傳送的資訊
string queue_name = "down";
connectionfactory factory = new connectionfactory();
factory.sethost("ip");
factory.setport(5672);
//基於網路環境合理設定超時時間
factory.setconnectiontimeout(30 * 1000);
factory.sethandshaketimeout(30 * 1000);
factory.setshutdowntimeout(0);
factory.setvirtualhost("real_time");
factory.setusername("username");
factory.setpassword("password");
connection connection = null;
channel channel = null;
try catch (ioexception e) catch (timeoutexception e) finally catch (ioexception e) catch (timeoutexception e)
}if (connection != null) catch (ioexception e)
}}
阿里雲搭建rabbitmq
最近在自己的阿里雲上面搭建了乙個rabbitmq，花了幾個小時，碰到了一些問題記錄一下 在這裡面把 搜尋 tcp listeners 更改為 在這個配置檔案裡面可以看到相關的配置資訊 2 在這個部落格裡面有新增使用者，賦予許可權的方式 現在說一下我當時遇到的問題，本來按照上面的方式以為就可以了，一直...
RabbitMQ常規操作（golang）
建立rabbitmq結構體例項 func newrabbitmq queuename string exchange string key string rabbitmq var err error rabbitmq.conn,err amqp.dial rabbitmq.mqurl rabbitm...
RabbitMQ搭建流程
rabbitmq是最受歡迎的開源訊息中介軟體之一，在全球範圍內被廣泛應用。rabbitmq是輕量級且易於部署的，能支援多種訊息協議。rabbitmq可以部署在分布式系統中，以滿足大規模 高可用的要求。我們先來了解下rabbitmq中的相關概念，這裡以5種訊息模式中的路由模式為例 640.png 1 ...