快捷導(dǎo)航

java發(fā)送http請求時(shí)如何處理異步回調(diào)結(jié)果

更新時(shí)間：2024年06月01日 09:53:06 作者：JAVA葉知秋

這篇文章主要介紹了java發(fā)送http請求時(shí)如何處理異步回調(diào)結(jié)果問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

java發(fā)送http請求時(shí)處理異步回調(diào)結(jié)果

maven依賴

<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpasyncclient</artifactId>
			<version>4.1.1</version>
		</dependency>

1.線程類負(fù)責(zé)處理業(yè)務(wù)

package com.ruoyi.test;
 
import java.io.UnsupportedEncodingException;
 
/**
 * Created with IDEA
 * author:QinWei
 * Date:2019/4/10
 * Time:10:28
 */
public class Business extends Thread{
    // 回答1+1，很簡單的問題不需要線程
    public int add(int num1, int num2) {
        return num1 + num2;
    }
 
    // 重寫run方法
    @Override
    public void run() {
        // 回答地球?yàn)槭裁词菆A的
        askquestion();
        super.run();
    }
 
    // 回調(diào)接口的創(chuàng)建，里面要有一個(gè)回調(diào)方法
    //回調(diào)接口什么時(shí)候用呢？這個(gè)思路是最重要的
    //
 
    public static interface Calls {
        public void call(String question);
    }
 
    // 回調(diào)接口的對象
    Calls calls;
 
    // 回答地球?yàn)槭裁词菆A的
    private void askquestion()  {
        System.err.println("開始查找資料！");
        try {
           // 業(yè)務(wù)請求處理
            String succes = Test.main();
 
            // 把答案返回到回調(diào)接口的call方法里面
            if (calls!=null) {//提問者實(shí)例化callPhone對象，相當(dāng)于提問者已經(jīng)告訴我，我到時(shí)用什么方式回復(fù)答案
                //這個(gè)接口的方法實(shí)現(xiàn)是在提問者的類里面
                calls.call(succes);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
 
 
    }
}

2.請求接口類

package com.ruoyi.test;
 
import com.ruoyi.common.json.JSONObject;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.concurrent.FutureCallback;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
import org.apache.http.impl.nio.client.HttpAsyncClients;
import org.apache.http.util.EntityUtils;
 
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.concurrent.CountDownLatch;
 
/**
 * Created with IDEA
 * author:QinWei
 * Date:2019/4/10
 * Time:9:15
 */
public class Test {
 
    public static String main() throws UnsupportedEncodingException {
        final String[] resData = new String[1];
        CloseableHttpAsyncClient client = HttpAsyncClients.createDefault();
        client.start();
        final CountDownLatch latch = new CountDownLatch(1);
        final HttpPost post = new HttpPost("http://127.0.0.1:8088/login");
        String param1="loginName=6210308024916652&password=123456&captcha=10";
        JSONObject param2= new JSONObject();
        param2.put("loginName", "6210308024916652");
        param2.put("password", "123456");
        param2.put("captcha", "4");
        //設(shè)置請求頭    這里根據(jù)個(gè)人來定義
        post.addHeader("Content-type", "application/json; charset=utf-8");
        post.setHeader("Accept", "application/json");
        StringEntity stringEntity = new StringEntity(param2.toString());
        post.setEntity(stringEntity);
        //執(zhí)行
        client.execute(post, new FutureCallback<HttpResponse>() {
            //執(zhí)行異步操作  請求完成后
            @Override
            public void completed(final HttpResponse response) {
                latch.countDown();
                //響應(yīng)內(nèi)容
                int a = response.getStatusLine().getStatusCode();
                System.out.println("狀態(tài)碼:"+a);
                if (a == 200) {
                    HttpEntity entity = response.getEntity();
                    try {
                        resData[0] = EntityUtils.toString(entity);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    System.out.println("成功!");
                } else {
                    try {
                        //輸出響內(nèi)容
                        System.out.println(response.getStatusLine().getStatusCode()
                                + "  " + EntityUtils.toString(response.getEntity(), "UTF-8"));
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
 
            //請求失敗處理
            @Override
            public void failed(final Exception ex) {
                latch.countDown();
            }
 
            //請求取消后處理
            @Override
            public void cancelled() {
                latch.countDown();
            }
 
        });
 
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //關(guān)閉
        try {
            client.close();
        } catch (IOException ignore) {
 
        }
        return resData[0];
    }
}

3.測試類

package com.ruoyi.test;
 
/**
 * Created with IDEA
 * author:QinWei
 * Date:2019/4/10
 * Time:10:28
 */
public class MainClass {
 
    /**
     * java回調(diào)方法的使用
     * 實(shí)際操作時(shí)的步驟：（以本實(shí)例解釋）
     * 1.在回答者的類內(nèi)創(chuàng)建回調(diào)的接口
     * 2.在回答者的類內(nèi)創(chuàng)建回調(diào)接口的對象，
     * 3.在提問者類里面實(shí)例化接口對象，重寫接口方法
     * 2.-3.這個(gè)點(diǎn)很重要，回調(diào)對象的實(shí)例化，要在提問者的類內(nèi)實(shí)例化，然后重寫接口的方法
     * 相當(dāng)于提問者先把一個(gè)聯(lián)絡(luò)方式給回答者，回答者找到答案后，通過固定的聯(lián)絡(luò)方式，來告訴提問者答案。
     * 4.調(diào)用開始新線程的start方法
     * 5.原來的提問者還可以做自己的事
     * */
    public static void main(String[] args) {
        // 小王問小張1+1=？，線程同步
        Business xiaoZhang = new Business();
        int i = xiaoZhang.add(1, 1);//回答1+1的答案
 
        // 問小張地球?yàn)槭裁词菆A的？回調(diào)方法的使用
        //這相當(dāng)于先定好一個(gè)返答案的方式，再來執(zhí)行實(shí)際操作
 
        // 實(shí)例化回調(diào)接口的對象
        Business.Calls call = new Business.Calls() {
            @Override
            public void call(String question) {
                //回答問題者，回答后，才能輸出答案
                System.err.println(question);
            }
        };
 
        //把回調(diào)對象賦值給回答者的回調(diào)對象，回答問題者的回調(diào)對象才能回答問題
        xiaoZhang.calls = call;
 
        System.out.println("吩咐完畢！");
        //相關(guān)交代完畢之后再執(zhí)行查詢操作
        xiaoZhang.start();
 
        //小王做自己的事！
        System.out.println("處理自己的業(yè)務(wù)");
    }
}