資源簡介
包含通過http方式調用rabbitmq對外接口,如查看隊列的有效性、獲取交換機等信息
包含通過http方式調用rabbitmq對外接口,如查看隊列的有效性、獲取交換機等信息
包含通過http方式調用rabbitmq對外接口,如查看隊列的有效性、獲取交換機等信息
包含通過http方式調用rabbitmq對外接口,如查看隊列的有效性、獲取交換機等信息

代碼片段和文件信息
package?com.test;
import?javax.xml.bind.DatatypeConverter;
import?org.apache.http.HttpEntity;
import?org.apache.http.HttpResponse;
import?org.apache.http.client.methods.HttpGet;
import?org.apache.http.conn.scheme.PlainSocketFactory;
import?org.apache.http.conn.scheme.Scheme;
import?org.apache.http.conn.scheme.SchemeRegistry;
import?org.apache.http.conn.ssl.SSLSocketFactory;
import?org.apache.http.impl.client.DefaultHttpClient;
import?org.apache.http.impl.conn.PoolingClientConnectionManager;
import?org.apache.http.params.BasicHttpParams;
import?org.apache.http.params.HttpParams;
import?org.apache.http.util.EntityUtils;
public?class?Test?{
public?static?void?main(String[]?args)?throws?Exception?{
// /api/queues/vhost/name
// /api/queues
String?httpurl?=?“http://server:15672/api/queues/%2F/sitech.devops.deploy.queue/bindings“;
/**
?*?1.初始化client
?*/
String?CODE_ENCODING?=?“UTF-8“;
HttpParams?httpParams?=?new?BasicHttpParams();
httpParams.setParameter(“charset“?CODE_ENCODING);
SchemeRegistry?schreg?=?new?SchemeRegistry();????
schreg.register(new?Scheme(“http“80PlainSocketFactory.getSocketFactory()));???
schreg.register(new?Scheme(“https“?443?SSLSocketFactory.getSocketFactory()));
PoolingClientConnectionManager?pccm?=?new?PoolingClientConnectionManager(schreg);??
pccm.setDefaultMaxPerRoute(20);?//每個主機的最大并行鏈接數???
pccm.setMaxTotal(100);?//客戶端總并行鏈接最大數?
DefaultHttpClient?client?=??new?DefaultHttpClient(pccmhttpParams);?
/**
?*?2.連接
?*/
HttpGet?get?=?new?HttpGet(httpurl);
get.addHeader(“Content-Type“?“application/json;charset=“?+?CODE_ENCODING);
get.setHeader(“Accept“?“application/json“);
get.setHeader(“Content-Type“?“application/json;charset=“?+?CODE_ENCODING);
String?authorization?=?DatatypeConverter.printbase64Binary(“guest:guest“.getBytes(“UTF-8“));
System.out.println(authorization);
get.setHeader(“Authorization“?“Basic?“+authorization);
HttpResponse?res?=?client.execute(get);
int?statusCode?=?res.getStatusLine().getStatusCode();
//?判斷返回編碼是否為200
if?(statusCode?!=?200?&&?statusCode?!=?201)?{
throw?new?Exception(“Get?“?+?httpurl?+?“Error!Response?Code?“?+?statusCode);
}
HttpEntity?entity?=?res.getEntity();
String?response?=?EntityUtils.toString(entity?CODE_ENCODING);
System.out.println(response);
}
}
?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件????????561??2018-03-01?15:33??RabbitMQHttpApi\.classpath
?????文件????????391??2018-03-01?15:31??RabbitMQHttpApi\.project
?????文件????????598??2018-03-01?15:31??RabbitMQHttpApi\.settings\org.eclipse.jdt.core.prefs
?????文件???????3857??2018-03-01?15:36??RabbitMQHttpApi\bin\com\test\Test.class
?????文件?????305001??2017-06-24?09:34??RabbitMQHttpApi\lib\commons-httpclient-3.1.jar
?????文件??????52915??2016-10-13?16:15??RabbitMQHttpApi\lib\commons-logging-1.1.jar
?????文件?????433368??2018-02-01?09:14??RabbitMQHttpApi\lib\httpclient-4.2.5.jar
?????文件?????227275??2018-02-01?09:14??RabbitMQHttpApi\lib\httpcore-4.2.4.jar
?????文件???????2463??2018-03-01?15:36??RabbitMQHttpApi\src\com\test\Test.java
?????目錄??????????0??2018-03-01?15:33??RabbitMQHttpApi\bin\com\test
?????目錄??????????0??2018-03-01?15:32??RabbitMQHttpApi\src\com\test
?????目錄??????????0??2018-03-01?15:33??RabbitMQHttpApi\bin\com
?????目錄??????????0??2018-03-01?15:32??RabbitMQHttpApi\src\com
?????目錄??????????0??2018-03-01?15:31??RabbitMQHttpApi\.settings
?????目錄??????????0??2018-03-01?15:33??RabbitMQHttpApi\bin
?????目錄??????????0??2018-03-01?15:32??RabbitMQHttpApi\lib
?????目錄??????????0??2018-03-01?15:32??RabbitMQHttpApi\src
?????目錄??????????0??2018-03-01?15:31??RabbitMQHttpApi
-----------?---------??----------?-----??----
??????????????1026429????????????????????18
- 上一篇:千套網站設計模板及源碼
- 下一篇:主軸零件圖
評論
共有 條評論