搭建rabbitMq 阿里 和 常規

2021-10-01 08:28:40 字數 1996 閱讀 6146

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 ...