更新

leutu

2024-08-27 55e607b91e8058a7fe713fa07cd4c829b5593aa5

 src/main/java/com/yb/util/OkHttpUtil.java

@@ -1,10 +1,9 @@
package com.yb.util;

import com.alibaba.fastjson.JSON;
import com.google.gson.Gson;
import com.yb.entity.ResponseEntity;
import okhttp3.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RestController;

@@ -12,6 +11,7 @@
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.TimeUnit;

@Component
@RestController
@@ -28,8 +28,13 @@
    // get请求
    public  String getMessage(String url)  {
        try {
            OkHttpClient client = new OkHttpClient();
            OkHttpClient client = new OkHttpClient.Builder()
                    .connectTimeout(5, TimeUnit.SECONDS)
                    .readTimeout(5, TimeUnit.SECONDS)
                    .writeTimeout(5, TimeUnit.SECONDS)
                    .build();
            Request request = new Request.Builder()

                    .url(url)
                    .build();

@@ -80,6 +85,7 @@
        return  null ;
    }

    @Async
    public String requesFast(String message){
        System.out.println("fastgpt:"+message) ;
       OkHttpClient client = new OkHttpClient();
@@ -137,7 +143,7 @@
                    int index = rep.indexOf("flowResponses");
                    int index_s = rep.indexOf("data", index);
                    String data = rep.substring(index_s + 5);
                    System.out.println(data);
                    System.out.println("data is ok....");
                    return data;
                }else{
                    return rep ;