rabbitmq接口異常函數方法_RabbitMQ監控（三）：監控隊列狀態

#RabbitMQ 監控(三)

驗證RabbitMQ健康運行只是確保消息通信架構可靠性的一部分，同時，你也需要確保消息通信結構配置沒有遭受意外修改，從而避免應用消息丟失。

RabbitMQ Management HTTP API提供了一個方法允許你查看任何vhost上的任何隊列：/api/queues//。你不僅可以查看配置詳情，還可以查看隊列的數據統計，例如隊列消耗的內存，或者隊列的平均消息吞吐量。使用curl測試一下該API，這里的/%2F還是代表默認的vhost(/)。

curl -u guest:guest http://127.0.0.1:15672/api/queues/%2F/springrabbitexercise

response

{

"consumer_details": [

{

"channel_details": {

"peer_host": "127.0.0.1",

"peer_port": 62679,

"connection_name": "127.0.0.1:62679 -> 127.0.0.1:5672",

"user": "guest",

"number": 2,

"node": "rabbit@localhost",

"name": "127.0.0.1:62679 -> 127.0.0.1:5672 (2)"

},

"arguments": [],

"prefetch_count": 1,

"ack_required": true,

"exclusive": false,

"consumer_tag": "amq.ctag-YImeU8Fm_VahDpxv8EAw2Q",

"queue": {

"vhost": "/",

"name": "springrabbitexercise"

}

}

],

"messages_details": {

"rate": 7357

},

"messages": 232517,

"messages_unacknowledged_details": {

"rate": 0.2

},

"messages_unacknowledged": 5,

"messages_ready_details": {

"rate": 7356.8

},

"messages_ready": 232512,

"reductions_details": {

"rate": 1861021.8

},

"reductions": 58754154,

...

"auto_delete": false,

"durable": true,

"vhost": "/",

"name": "springrabbitexercise",

"message_bytes_persistent": 2220250,

"message_bytes_ram": 2220250,

"message_bytes_unacknowledged": 40,

"message_bytes_ready": 2220210,

"message_bytes": 2220250,

"messages_persistent": 232517,

"messages_unacknowledged_ram": 5,

"messages_ready_ram": 232512,

"messages_ram": 232517,

"garbage_collection": {

"minor_gcs": 0,

"fullsweep_after": 65535,

"min_heap_size": 233,

"min_bin_vheap_size": 46422,

"max_heap_size": 0

},

"state": "running"

}

為了方便閱讀，去掉了部分返回值，但是還是可以看到隊列的很多信息。例如可以看到一個consumer的信息、消息占用的內存、隊列的durable、auto_delete屬性等。利用這些配置信息，新的健康監控程序可以通過API方法的輸出來輕松監控隊列的屬性，并在發生變更時通知你。

就像之前編寫健康檢測程序那樣，除了服務器、端口、vhost、用戶名和密碼之外，還需要知道：

* 隊列的名稱，以便監控其配置

* 該隊列是否將durable和auto_delete選項打開

###清單3.1 檢測隊列配置

完整代碼在我的github，下面代碼中的@Data和@Slf4j都是插件lombok中的注解，想要了解的可自行百度。

1.定義查看隊列信息的接口 RMQResource.java

@Path("api")

@Consumes({MediaType.APPLICATION_JSON})

@Produces({MediaType.APPLICATION_JSON})

public interface RMQResource {

/**

* Return a queue`s info

*

* @param vhost

* @param name

* @return {@link QueueInfo}

*/

@GET

@Path("queues/{vhost}/{name}")

Response getQueueInfo(@PathParam("vhost") String vhost, @PathParam("name") String name);

}

2.定義查看隊列接口的返回值 QueueInfo.java

@Data

public class QueueInfo {

private ConsumerDetails[] consumer_details;

/**

* unknown class

*/

@JsonIgnore

private Object[] incoming;

/**

* unknown class

*/

@JsonIgnore

private Object[] deliveries;

/**

* unknown class

*/

@JsonIgnore

private Object arguments;

private Boolean exclusive;

//...

private Boolean auto_delete;

private Boolean durable;

private String vhost;

private String name;

/**

* unknown class

*/

@JsonIgnore

private Object head_message_timestamp;

/**

* unknown class

*/

@JsonIgnore

private Object recoverable_slaves;

private Long memory;

private Double consumer_utilisation;

private Integer consumers;

/**

* unknown class

*/

@JsonIgnore

private Object exclusive_consumer_tag;

/**

* unknown class

*/

@JsonIgnore

private Object policy;

@JsonFormat(pattern = "yyyy-MM-dd hh:mm:ss")

private Date idle_since;

}

3.檢測隊列配置 QueueConfigCheck.java

/**

* 檢測隊列配置

*/

@Slf4j

public class QueueConfigCheck {

private final static RMQResource rmqResource = RMQApi.getService(RMQResource.class);

public static void checkQueueConfig(String vhost, CheckQueue queue) {

RMQConfig config = RMQConfig.Singleton.INSTANCE.getRmqConfig();

String host = config.getHost();

Response response = null;

try {

response = rmqResource.getQueueInfo(vhost, queue.getQueue_name());

} catch (Exception e) {

log.error("UNKNOWN: Could not connect to {}, cause {}", host, e.getMessage());

ExitUtil.exit(ExitType.UNKNOWN.getValue());

}

if (response == null || response.getStatus() == 404) {

log.error("CRITICAL: Queue {} does not exist.", queue.getQueue_name());

ExitUtil.exit(ExitType.CRITICAL.getValue());

} else if (response.getStatus() > 299) {

log.error("UNKNOWN: Unexpected API error : {}", response);

ExitUtil.exit(ExitType.UNKNOWN.getValue());

} else {

QueueInfo info = response.readEntity(QueueInfo.class);

if (!info.getAuto_delete().equals(queue.getAuto_delete())) {

log.warn("WARN: Queue {} - auto_delete flag is NOT {}", queue.getQueue_name(), info.getAuto_delete());

ExitUtil.exit(ExitType.WARN.getValue());

}

if (!info.getDurable().equals(queue.getDurable())) {

log.warn("WARN: Queue {} - durable flag is NOT {}", queue.getQueue_name(), info.getDurable());

ExitUtil.exit(ExitType.WARN.getValue());

}

}

log.info("OK: Queue {} configured correctly.", queue.getQueue_name());

ExitUtil.exit(ExitType.OK.getValue());

}

}

4.檢測隊列配置的方法參數 CheckQueue.java

@Data

public class CheckQueue {

private final String queue_name;

private final Boolean auto_delete;

private final Boolean durable;

public CheckQueue(String queue_name, Boolean auto_delete, Boolean durable) {

this.queue_name = queue_name;

this.auto_delete = auto_delete;

this.durable = durable;

}

}

5.運行檢測程序

@Test

public void testQueueConfig() {

String queue_name = "springrabbitexercise";

Boolean auto_delete = false;

Boolean durable = true;

String vhost = "/";

CheckQueue queue = new CheckQueue(queue_name, auto_delete, durable);

QueueConfigCheck.checkQueueConfig(vhost, queue);

}

可以看到監控正常運行：

11:38:23.286 [main] INFO com.lanxiang.rabbitmqmonitor.check.QueueConfigCheck - OK: Queue springrabbitexercise configured correctly.

11:38:23.289 [main] INFO com.lanxiang.rabbitmqmonitor.terminate.ExitUtil - Status is OK

這段RabbitMQ隊列檢測的程序有一處修改，如果健康檢測程序無法連接到API服務器的話，會返回EXIT_UNKNOWN。前一章的API ping健康檢測要么成功要么失敗，故障代碼之間沒有區別，但是隊列檢測API方法在失敗時通過HTTP狀態碼提供了更多信息。如果HTTP狀態碼是404就代表嘗試驗證的隊列不存在，檢測失敗并返回EXIT_CRITICAL。對于其他大于299的HTTP狀態碼，退出代碼為EXIT_UNKNOWN。

在獲取到RabbitMQ API的response之后，使用JSON進行解碼，并且把得到的durable和auto_delete參數與期望的參數進行比較，如果參數和預期不相符的話，返回EXIT_WARNING或者EXIT_CRITICAL狀態碼。如果隊列所有的配置都正確的話，那么就正確退出。

在了解我們對RabbitMQ做監控的原理之后，可以根據RabbitMQ Management HTTP API定制更多的監控，例如：

* /api/nodes，可以獲取集群中每個節點的數據

* /api/queues//，可以獲取隊列的詳細情況，例如消息處理的速率、積壓的消息數量等。

除此之外還有許多其他API，我們要做的就是根據自身的業務邏輯和這些API來設計合理的監控腳本。RabbitMQ監控系列就到此結束啦，還是很可惜沒有實戰的機會吧，因為最近在工作變動期間，看了一下RabbitMQ實戰這本書，興起想寫一下博客試試。

畢業快一年了，想養成寫博客的習慣。正好最近也在工作變動中，能有閑暇時間嘗試一下，博客寫的比較水，多多包涵。

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/454983.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/454983.shtml
英文地址，請注明出處：http://en.pswp.cn/news/454983.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

FFMpeg語法參數中文參考手冊

FFMpeg語法參數中文參考手冊

要查看你的ff mpeg支持哪些 格式，可以用如下命令：$ ffmpeg -formats | less還可以把 視頻文件導出成jpg序列幀：$ ffmpeg -i bc-cinematic-en.avi example.%d.jpgdebian下安裝ffmpeg很簡單：＃apt-get install ffmpegffmp…
閱讀更多...
Java類集框架 —— LinkedHashMap源碼分析

Java類集框架 —— LinkedHashMap源碼分析

前言 我們知道HashMap底層是采用數組單向線性鏈表/紅黑樹來實現的，HashMap在擴容或者鏈表與紅黑樹轉換過程時可能會改變元素的位置和順序。如果需要保存元素存入或訪問的先后順序，那就需要采用LinkedHashMap了。 LinkedHashMap結構 LinkedHashMap繼承自H…
閱讀更多...
apache 支持.htaccess重寫url

apache 支持.htaccess重寫url

1. httpd.conf 添加&#xff1a; <Directory />Options Indexes FollowSymLinks MultiviewsAllowOverride allRequire all grantedRewriteEngine On</Directory> 開啟&#xff1a; 在phpinfo里找到&#xff1a; 說明開啟成功。 2.httpd-vhosts.conf &#xff08;開…
閱讀更多...
oom 如何避免 高并發_【高并發】高并發環境下如何防止Tomcat內存溢出？看完我懂了！！...

oom 如何避免 高并發_【高并發】高并發環境下如何防止Tomcat內存溢出？看完我懂了！！...

【高并發】高并發環境下如何防止Tomcat內存溢出&#xff1f;看完我懂了&#xff01;&#xff01;發布時間&#xff1a;2020-04-19 00:47,瀏覽次數&#xff1a;126, 標簽&#xff1a;Tomcat寫在前面隨著系統并發量越來越高&#xff0c;Tomcat所占用的內存就會越來越大&#xff0…
閱讀更多...
[JSOI2008]最小生成樹計數

[JSOI2008]最小生成樹計數

OJ題號&#xff1a;　　BZOJ1016 題目大意&#xff1a; 　　給定一個無向帶權圖&#xff0c;求最小生成樹的個數。 思路&#xff1a; 　　先跑一遍最小生成樹&#xff0c;統計相同權值的邊出現的個數。 　　易證不同的最小生成樹&#xff0c;它們不同的那一部分邊的權值實際上是…
閱讀更多...
vuex webpack 配置_vue+webpack切換環境和打包之后服務器配置

vuex webpack 配置_vue+webpack切換環境和打包之后服務器配置

import axios from ‘axios‘import store from ‘../store/index‘const rootUrl process.env.API_ROOT//創建axios實例const service axios.create({timeout:30000 //超時時間})//添加request攔截器service.interceptors.request.use(config >{if (Object.keys(config.hea…
閱讀更多...
redis基本用法學習（C#調用FreeRedis操作redis）

redis基本用法學習（C#調用FreeRedis操作redis）

FreeRedis屬于常用的基于.net的redis客戶端&#xff0c;EasyCaching中也提供適配FreeRedis的包。根據參考文獻4中的說法&#xff0c;FreeRedis和CsRedis算是近親&#xff08;都是GitHub中賬號為2881099下的開源項目&#xff09;&#xff0c;因此其用法特別相似。FreeRedis的主要…
閱讀更多...
opencv:圖像的基本變換

opencv:圖像的基本變換

0.概述 圖像變換的基本原理都是找到原圖和目標圖的像素位置的映射關系&#xff0c;這個可以用坐標系來思考&#xff0c;在opencv中&#xff0c; 圖像的坐標系是從左上角開始(0,0)&#xff0c;向右是x增加方向(cols)&#xff0c;向下時y增加方向(rows)。 普通坐標關系&#xff1…
閱讀更多...
FFMpeg在Windows環境下的編譯

FFMpeg在Windows環境下的編譯

1&#xff0e;安裝MinGW &#xff08;1&#xff09;下載文件&#xff1a;MinGW-5.1.4.exe&#xff0c; &#xff08;2&#xff09;安裝時選擇下列組件&#xff1a; binutils-2.19.1-mingw32-bin.tar.gz gcc-core-3.4.5-20060117-3.tar.gz gcc-g-3.4.5-20060117-3.tar.gz …
閱讀更多...
中通知設置響鈴_主動切斷干擾源——手機“通知”精細化管理

中通知設置響鈴_主動切斷干擾源——手機“通知”精細化管理

上周去參加我福福幼兒園的母親節活動&#xff0c;內容是孩子和家長一起穿手鏈。期間我發現和我同桌的一個家長的手機不停在響&#xff0c;當然伴隨著注意力被打斷。不僅是這位家長自己&#xff0c;連我也受到了干擾。于是職業病又犯了&#xff0c;我悄悄的看了一眼這位家長的手…
閱讀更多...
OCM_第十九天課程：Section9 —》Data Guard _ DATA GUARD 原理/DATA GUARD 應用/DATA GUARD 搭建...

OCM_第十九天課程：Section9 —》Data Guard _ DATA GUARD 原理/DATA GUARD 應用/DATA GUARD 搭建...

注&#xff1a;本文為原著&#xff08;其內容來自 騰科教育培訓課堂&#xff09;。閱讀本文注意事項如下&#xff1a;1&#xff1a;所有文章的轉載請標注本文出處。2&#xff1a;本文非本人不得用于商業用途。違者將承當相應法律責任。3&#xff1a;該系列文章目錄列表&#xf…
閱讀更多...
python安裝各種插件

python安裝各種插件

http://www.lfd.uci.edu/~gohlke/pythonlibs/#pip 感受&#xff1a;如果編輯pip真的一直出問題&#xff0c;考慮降成32位的進行安裝。畢竟合理搭配比木桶突出有用。轉載于:https://www.cnblogs.com/osmondwang/p/7307678.html
閱讀更多...
編寫數學公式的好工具

編寫數學公式的好工具

2019獨角獸企業重金招聘Python工程師標準>>> http://private.codecogs.com/latex/eqneditor.php 轉載于:https://my.oschina.net/yizhichao/blog/1542153
閱讀更多...
dev gridview 打印列數過多_R語言：如何將多張統計圖繪制在一張上面

dev gridview 打印列數過多_R語言：如何將多張統計圖繪制在一張上面

在使用R語言進行數據可視化的時候&#xff0c;常常需要將多張統計圖表繪制在同一張圖上面&#xff0c;從而更高效地傳遞信息&#xff0c;下面我們就來一起看看具體如何實現。一、使用R語言自帶的函數繪制的圖像R語言本身就已經內置了許多繪圖函數&#xff0c;能夠滿足較為基本的…
閱讀更多...
264分析兩大利器 和 視頻系列下載：264VISA和Elecard StreamEye Tools

264分析兩大利器 和 視頻系列下載：264VISA和Elecard StreamEye Tools

學了264有將近3個月有余&#xff0c;好多時候都在學習老畢的書和反復看JM86的代碼&#xff0c;最近才找到264分析兩大利器&#xff1a;264VISA和Elecard StreamEye Tools。不由得感嘆&#xff0c;恨不逢同時。 簡單的說下這兩個軟件&#xff1a; 264visa 強力的h264實時分析工具…
閱讀更多...
[轉]vue全面介紹--全家桶、項目實例

[轉]vue全面介紹--全家桶、項目實例

慢慢了解vue及其全家桶的過程 原文http://blog.csdn.net/zhenghao35791/article/details/67639415 簡介 “簡單卻不失優雅&#xff0c;小巧而不乏大匠”。 2016年最火的前端框架當屬Vue.js了&#xff0c;很多使用過vue的程序員這樣評價它&#xff0c;“vue.js兼具angular.js和R…
閱讀更多...
opencv 星空_opencv如何將大于5000像素點的輪廓繪制出來？

opencv 星空_opencv如何將大于5000像素點的輪廓繪制出來？

contourArea函數的運用。具體例子可以看下面的。《如何獲得物體的主要方向&#xff1f;》代碼略解&#xff1a;1、讀入圖片&#xff0c;尋找輪廓&#xff1b;//讀入圖像&#xff0c;轉換為灰度Mat img imread("e:/sandbox/pca1.jpg");Mat bw;cvtColor(img, bw, COLO…
閱讀更多...
TS 188字節流結構圖

TS 188字節流結構圖

應該說真正了解TS&#xff0c;還是看了朋友推薦的《數字電視業務信息及其編碼》一書之后&#xff0c;MPEG2 TS和數字電視是緊密不可分割的&#xff0c;值得總結一下其中的一些關系。 ISO/IEC&#xff0d;13818&#xff0d;1&#xff1a;系統部分&#xff1b; ISO/IEC&#xff…
閱讀更多...
二進制安裝mysql 5.7、mariadb (附yum安裝方式)

二進制安裝mysql 5.7、mariadb (附yum安裝方式)

前言&#xff1a;本文以mariadb為例進行講解&#xff0c;安裝mysql同理&#xff0c;并以通過測試。安裝前查找系統已安裝的相關包&#xff08;rpm -qa|grep -e "mysql" -e "mariadb"&#xff09;并進行卸載。1、準備mariadb存儲數據庫文件的目錄。mkdir -p…
閱讀更多...
GLSL/C++ 實現濾鏡效果

GLSL/C++ 實現濾鏡效果

入門效果之浮雕 "浮雕"圖象效果是指圖像的前景前向凸出背景。常見于一些紀念碑的雕刻上。要實現浮雕事實上很easy。我們把圖象的一個象素和左上方的象素進行求差運算。并加上一個灰度。這個灰度就是表示背景顏色。這里我們設置這個插值為128 (圖象RGB的值是0-255)。同…
閱讀更多...
最新文章

Copyright @ 2022~2023