快捷導(dǎo)航

Java接收text/event-stream格式數(shù)據(jù)的詳細(xì)代碼

更新時(shí)間：2023年07月20日 11:01:46 作者：明天我來了

這篇文章主要介紹了java接收text/event-stream格式數(shù)據(jù),本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

java接收text/event-stream格式數(shù)據(jù),并且解決接收HTTPS會(huì)不是流式輸出問題

前段時(shí)間因?yàn)橐獙?duì)接語音轉(zhuǎn)文字接口，對(duì)方接口輸出的是text/event-stream返回，返回的是流式輸出，本人在百度找了好久，一直沒有找到關(guān)于怎么接收流式返回的文章，可能很多人不清楚流式輸出指的是什么，流式輸出是和對(duì)方建立一個(gè)長(zhǎng)連接，接口方會(huì)一直不斷的給我們推送數(shù)據(jù)，而不用等待對(duì)方接口完全輸出后在把返回值一次性返回。

先貼代碼

get請(qǐng)求

public String getEventStream(String urlStr, HttpServletResponse response) {
        long statr = System.currentTimeMillis();
        log.info("開始請(qǐng)求接口url:{}", urlStr);
        InputStream is = null;
        StringBuffer bu = new StringBuffer();
        try {
            URL url = new URL(urlStr);
            URLConnection conn = url.openConnection();
            is = conn.getInputStream();
            byte[] b = new byte[1024];
            int len = -1;
            long end = System.currentTimeMillis();
            log.info("接口url:{},請(qǐng)求開始流式輸出{}", urlStr, end - statr);
            while ((len = is.read(b)) != -1) {
                String line = new String(b, 0, len, "utf-8");
                // 處理 event stream 數(shù)據(jù)
                response.getWriter().write(line);
                response.getWriter().flush();
                bu.append(line);
            }
        } catch (IOException e) {
            log.error("請(qǐng)求模型接口異常", e);
            throw new BusinessException(ResponseCode.TOPIC_INITIATION_FAILED);
        } finally {
            if (!Objects.isNull(is)) {
                try {
                    //12.關(guān)閉輸入流
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return bu.toString();
    }

這里的urlStr參數(shù)是url加參數(shù)，示例：https://baidu.com?text=12345678response是因?yàn)槲倚枰瑯佑昧魇捷敵鑫淖纸o前端，如果你不需要返回給前端，可以不用response參數(shù)。

post請(qǐng)求

public String postEventStream(String urlStr, String json, HttpServletResponse response) {
        long statr = System.currentTimeMillis();
        log.info("開始請(qǐng)求接口url:{},請(qǐng)求參數(shù){}", urlStr,json);
        InputStream is = null;
        //11.讀取輸入流中的返回值
        StringBuffer bu = new StringBuffer();
        try {
            //1.設(shè)置URL
            URL url = new URL(urlStr);
            //2.打開URL連接
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            //3.設(shè)置請(qǐng)求方式
            conn.setRequestMethod("POST");
            //4.設(shè)置Content-Type
            conn.setRequestProperty("Content-Type", "application/json;charset=utf-8");
            //5.設(shè)置Accept
            conn.setRequestProperty("Accept", "text/event-stream");
            //6.設(shè)置DoOutput
            conn.setDoOutput(true);
            //7.設(shè)置DoInput
            conn.setDoInput(true);
            //8.獲取輸出流
            OutputStream os = conn.getOutputStream();
            //9.寫入?yún)?shù)（json格式）
            os.write(json.getBytes("utf-8"));
            os.flush();
            os.close();
            //10.獲取輸入流
            is = conn.getInputStream();
            byte[] bytes = new byte[1024];
            int len = 0;
            long end = System.currentTimeMillis();
            log.info("接口url:{},請(qǐng)求參數(shù){},請(qǐng)求開始流式輸出{}", urlStr,json, end - statr);
            while ((len = is.read(bytes)) != -1) {
                String line = new String(bytes, 0, len, "utf-8");
                response.getWriter().write(line);
                response.getWriter().flush();
                bu.append(line);
            }
        } catch (IOException e) {
            log.error("請(qǐng)求模型接口異常", e);
            throw new BusinessException(ResponseCode.TOPIC_INITIATION_FAILED);
        } finally {
            if (!Objects.isNull(is)) {
                try {
                    //12.關(guān)閉輸入流
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return bu.toString();
    }

第一次寫文章，表達(dá)不好請(qǐng)諒解，這里使用的jdk版本是1.8，如果對(duì)于springboot怎么樣返回給前端流式輸出有疑問，可以私信問我

到此這篇關(guān)于Java接收text/event-stream格式數(shù)據(jù)的詳細(xì)代碼的文章就介紹到這了,更多相關(guān)java接收text/event-stream格式數(shù)據(jù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: