2. 程式人生 > >rabbitMq配置到spring boot

rabbitMq配置到spring boot

阿新 • • 發佈：2019-01-25

Httpclient呼叫Util

maven配置

  1. <dependency>
  2. <groupId>com.alibaba</groupId>
  3. <artifactId>fastjson</artifactId>
  4. <version>1.2.46</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.apache.httpcomponents</groupId>
  8. <artifactId>httpclient</artifactId>
  9. <
    version>4.3.1</version>
  10. </dependency>

主要核心程式碼

GET方法

  1. privatestaticJSONObject sendAlaudaData(String url){
  2. JSONObject jsonObject=null;
  3. try{
  4. HttpGet httpGet =newHttpGet(DEFAULT_HOST_URL+url);
  5. httpGet.setHeader("Authorization", DEFAULT_TOKEN);
  6. httpGet.setHeader("Content-Type","application/json; charset=utf-8"
    );
  7. HttpClient client =HttpClients.createDefault();
  8. HttpResponse httpResponse = client.execute(httpGet);
  9. String respContent =EntityUtils.toString(httpResponse.getEntity(),"UTF-8");
  10. jsonObject =JSONObject.parseObject(respContent);
  11. }catch(UnsupportedEncodingException e){
  12. e.printStackTrace();
  13. }
    catch(IOException e){
  14. e.printStackTrace();
  15. }
  16. return jsonObject;
  17. }

POST方法

  1. /**
  2. * HttpClient link
  3. * @param jsonBody
  4. * @param url
  5. * @return
  6. */
  7. privatestaticJSONObject sendAlaudaData(String jsonBody,String url){
  8. JSONObject jsonObject =null;
  9. try{
  10. HttpPost httpPost =newHttpPost(DEFAULT_HOST_URL+url);
  11. StringEntity entity =newStringEntity(jsonBody,"UTF-8");
  12. httpPost.setHeader("Authorization", DEFAULT_TOKEN);
  13. httpPost.setHeader("Content-Type","application/json; charset=utf-8");
  14. httpPost.setEntity(entity);
  15. HttpClient client =HttpClients.createDefault();
  16. HttpResponse httpResponse = client.execute(httpPost);
  17. String respContent =EntityUtils.toString(httpResponse.getEntity(),"UTF-8");
  18. Object object =JSONObject.parse(respContent);
  19. if(object instanceofJSONObject){
  20. jsonObject=(JSONObject)object;
  21. }elseif(object instanceofJSONArray){
  22. jsonObject =((JSONArray) object).getJSONObject(0);
  23. }
  24. }catch(UnsupportedEncodingException e){
  25. e.printStackTrace();
  26. }catch(IOException e){
  27. e.printStackTrace();
  28. }
  29. return jsonObject;
  30. }

最後奉上完整程式碼

  1. import com.alibaba.fastjson.JSONArray;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.irootech.service.dto.SUserDTO;
  4. import org.apache.http.HttpResponse;
  5. import org.apache.http.client.HttpClient;
  6. import org.apache.http.client.methods.HttpGet;
  7. import org.apache.http.client.methods.HttpPost;
  8. import org.apache.http.entity.StringEntity;
  9. import org.apache.http.impl.client.HttpClients;
  10. import org.apache.http.util.EntityUtils;
  11. import java.io.IOException;
  12. import java.io.UnsupportedEncodingException;
  13. publicclassAlaudaAPI{
  14. privatefinalstaticString DEFAULT_HOST_URL ="http://<host>";
  15. privatefinalstaticString DEFAULT_TOKEN ="Token....";
  16. privatefinalstaticString DEFAULT_CLUSTER ="test";
  17. privatefinalstaticString APPS_URL ="apps";
  18. privatefinalstaticString SPACE ="-space";
  19. privatefinalstaticString ROLE ="-role";
  20. publicstaticvoid main(String[] args){
  21. /*JSONObject result = getRoleDetail("tes2t");
  22. System.out.println("========"+result.getJSONArray("errors"));*/
  23. String jsonN ="{\"username\": \"test_5\", \"password\": \"123456\"}";
  24. Object jsonObject =JSONObject.parse(jsonN);
  25. if(jsonObject instanceofJSONObject){
  26. JSONObject jsonObject1 =(JSONObject)jsonObject;
  27. System.out.println(jsonObject1);
  28. }elseif(jsonObject instanceofJSONArray){
  29. JSONObject jsonObject2 =((JSONArray) jsonObject).getJSONObject(0);
  30. System.out.println(jsonObject2);
  31. }
  32. System.out.println(jsonObject);
  33. }
  34. /**
  35. * HttpClient link

  36. 相關推薦

    RabbitMQ進階使用-延時佇列的配置(Spring Boot)

    依賴 MAVEN配置pom.xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spri

    rabbitMq與spring boot搭配實現監聽

    address app caching prefix 前段時間 ever 不用 理解 its 　　在我前面有一篇博客說到了rabbitMq實現與zk類似的watch功能，但是那一篇博客沒有代碼實例，後面自己補了一個demo，便於理解。demo中主要利用spring boot

    Linux系統CentOS 7配置Spring Boot運行環境

    創建 entos linux () 如果 博客 配置服務 oracle 自啟 從阿裏雲新買的一臺Linux服務器，用來部署SpringBoot應用，由於之前一直使用Debian版本，環境配置有所不同，也較為繁瑣，本文主要介紹CentOS下配置SpringBoot環境的過程

    配置spring boot 內建tomcat的accessLog日誌

    #配置內建tomcat的訪問日誌server.tomcat.accesslog.buffered=trueserver.tomcat.accesslog.directory=/home/hygw/logsserver.tomcat.accesslog.enabled=trueserver.tomcat.acc

    Linux系統CentOS 7配置Spring Boot執行環境

    從阿里雲新買的一臺Linux伺服器，用來部署SpringBoot應用，由於之前一直使用Debian版本，環境配置有所不同，也較為繁瑣，本文主要介紹CentOS下配置SpringBoot環境的過程 新建使用者 由於新拿到的機器只有root使用者，用

    rabbitmq 整合spring boot

    引入包 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-bo

    在IDEA中配置spring boot 對jsp頁面的支援

    現在前後的分離的，一般springboot 就用來做後臺restful 介面，那麼如果要前後端合併在springboot呢？可以通過下面幾個簡單的步驟，增加對jsp的支援。 （1）pom增加依賴： <!--springboot tomcat jsp 支援開啟--&g

    在IDEA中配置spring boot專案的熱更新

    在我使用IDEA的過程中,我發現Spring Boot專案本來自帶的一個熱部署工具無法使用,這裡在參考各家部落格後給出解決方案: 修改POM 首先POM檔案需要包含spring boot的熱部署工具,maven依賴如下: <dependency> <groupI

    如何使用Google作為認證方配置Spring Boot 2 Security5整合的OAuth2登入我們自己的工程專案------範例1

    Google客戶端授權生成client-id和client-secret我們需要登入以下地址 https://console.developers.google.com 第1部分： 範例工程專案結構如下： Enabling OAuth 2 login Supp

    RabbitMq在spring boot中整合和應用

    具體如果安裝rabbitmq在本例子中不涉及，主要講解在springboot中如果傳送和接收rabbitmq訊息。 1.新增依賴 <dependency> <groupId>org.springframewor

    如何配置Spring Boot Tomcat

    1.概述 Spring Boot Web應用程式預設包含預配置的嵌入式Web伺服器。但在某些情況下，我們要修改預設配置以滿足自定義要求。 在本教程中，我們將介紹通過application.properties檔案配置Tomcat嵌入式伺服器的一些常見用例。 2.常見的嵌入式Tomcat配置 2.1

    RabbitMQ（三）：RabbitMQ與Spring Boot簡單整合

    RabbitMQ是目前非常熱門的一款訊息中介軟體，不管是網際網路大廠還是中小企業都在大量使用。Spring Boot的興起，極大地簡化了Spring的開發，本文將使用Spring Boot與RabbitMQ進行簡單整合，實現生產和消費訊息。 配置 Spring Boot使用了這麼久，套路差不多摸清楚了。Spr

    Spring Boot項目配置RabbitMQ集群

    user spa 配置 per work number host nbsp onf //具體參看了配置的源碼 org.springframework.boot.autoconfigure.amqp.RabbitProperties //RabbitMQ單機

    Spring Boot專案配置RabbitMQ叢集

    //具體參看了配置的原始碼 org.springframework.boot.autoconfigure.amqp.RabbitProperties //RabbitMQ單機 spring:   rabbitmq:     host: localh

    rabbitMq配置到spring boot

    Httpclient呼叫Utilmaven配置<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><versio

    Spring Boot 配置多源的 RabbitMQ

    簡介 MQ 是開發中很平常的中介軟體，本文講述的是怎麼在一個Spring Boot專案中配置多源的RabbitMQ，這裡不過多的講

    spring boot環境配置

    project fda new 信息 fig 比較 fab imp image Eclipse+Maven創建webapp項目<一> 1、開啟eclipse，右鍵new——》other，如下圖找到maven project 2、選

    Spring Boot的常見配置項解析

    ava efi article 框架 ring 智能 1.7 version parent 1.spring-boot-starter-parent：springboot官方推薦的maven管理工具，最簡單的做法就是繼承它。 spring-boot-starter-pare

    如何編寫Spring-Boot自動配置

    not 做的 mage 沒有 stat oot classname ger 內容 摘要 本文主要介紹如何把一個spring的項目（特別是一些公共工具類項目），基於spring boot的自動配置的思想封裝起來，使其他Spring-Boot項目引入後能夠進行快速配置。 Aut

    RabbitMq 集成 spring boot 消息隊列 入門Demo

    spring boot rabbitmq 入門集成spring boot 集成 RabbitMq還是很方便的。現在來一個簡單的例子來集成rabbitmq。入門demo。主要概念：其中比較重要的概念有 4 個，分別為：虛擬主機，交換機，隊列，和綁定。虛擬主機：一個虛擬主機持有一組交換機、隊列和綁定。為什麽需要多