package com.ruoyi.buss.common;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.buss.domain.vo.RfIdVo;
|
|
import java.io.*;
|
import java.net.ConnectException;
|
import java.net.HttpURLConnection;
|
import java.net.SocketTimeoutException;
|
import java.net.URL;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.Future;
|
|
public class RfidUtil {
|
|
public static void main(String[] args) {
|
String result = sendJsonPost("http://192.168.0.2:10800/open/goods/task","{\"id\":12,\"name\":\"任务名称\", \"path\": \"路径信息\"}");
|
List<RfIdVo> list = new ArrayList<>();
|
list.add(new RfIdVo(1, "NAME1", "PATH1"));
|
list.add(new RfIdVo(2, "NAME2", "PATH2"));
|
list.add(new RfIdVo(3, "NAME3", "PATH3"));
|
list.add(new RfIdVo(4, "NAME4", "PATH4"));
|
list.add(new RfIdVo(5, "NAME5", "PATH5"));
|
list.add(new RfIdVo(6, "NAME6", "PATH6"));
|
|
System.out.println("正常" + result);
|
}
|
|
/**
|
* 异步发送请求
|
* @param url
|
* @param list
|
*/
|
public static void asyncSendJsonPost(String url, List<RfIdVo> list){
|
ExecutorService executor = Executors.newFixedThreadPool(50); // 根据网络调整线程数
|
List<Future<?>> futures = new ArrayList<>();
|
|
for (int i = 0, len = list.size(); i < len; i++) {
|
int finalI = i;
|
futures.add(executor.submit(() -> {
|
try {
|
URL realUrl = new URL(url);
|
HttpURLConnection conn = (HttpURLConnection)realUrl.openConnection();
|
conn.setRequestMethod("POST");
|
conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
conn.setRequestProperty("Accept", "*/*");
|
conn.setConnectTimeout(3000); // 3秒超时
|
conn.setDoOutput(true);
|
conn.setDoInput(true);
|
try(OutputStream os = conn.getOutputStream()){
|
byte[] input = JSONObject.toJSONString(list.get(finalI)).getBytes("utf-8");
|
os.write(input, 0, input.length);
|
}
|
conn.getResponseCode();
|
} catch (Exception ignored) {
|
System.out.println("发送RFID任务失败，请重试。"+ JSONObject.toJSONString(list.get(finalI)));
|
}
|
}));
|
}
|
executor.shutdown();
|
}
|
|
|
/**
|
* 向指定 URL 发送POST方法的请求
|
*
|
* @param url 发送请求的 URL
|
* @return 所代表远程资源的响应结果
|
*/
|
public static String sendJsonPost(String url, String jsonString) {
|
PrintWriter out = null;
|
BufferedReader in = null;
|
StringBuilder result = new StringBuilder();
|
try
|
{
|
URL realUrl = new URL(url);
|
HttpURLConnection conn = (HttpURLConnection)realUrl.openConnection();
|
|
conn.setRequestMethod("POST");
|
conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
conn.setRequestProperty("Accept", "*/*");
|
conn.setDoOutput(true);
|
conn.setDoInput(true);
|
try(OutputStream os = conn.getOutputStream()){
|
byte[] input = jsonString.getBytes("utf-8");
|
os.write(input, 0, input.length);
|
}
|
|
int responseCode = conn.getResponseCode();
|
if(responseCode == HttpURLConnection.HTTP_OK){
|
try(BufferedReader br = new BufferedReader(
|
new InputStreamReader(conn.getInputStream(), "utf-8")
|
)){
|
String responseLine;
|
while ((responseLine = br.readLine()) != null){
|
result.append(responseLine.trim());
|
}
|
System.out.println(result.toString());
|
}
|
}
|
conn.disconnect();
|
System.out.println("result=" + result);
|
}
|
catch (ConnectException e)
|
{
|
System.out.println("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + jsonString);
|
e.printStackTrace();
|
}
|
catch (SocketTimeoutException e)
|
{
|
System.out.println("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + jsonString);
|
e.printStackTrace();
|
}
|
catch (IOException e)
|
{
|
System.out.println("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + jsonString);
|
e.printStackTrace();
|
}
|
catch (Exception e)
|
{
|
System.out.println("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + jsonString);
|
e.printStackTrace();
|
}
|
finally
|
{
|
try
|
{
|
if (out != null)
|
{
|
out.close();
|
}
|
if (in != null)
|
{
|
in.close();
|
}
|
}
|
catch (IOException ex)
|
{
|
System.out.println("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + jsonString);
|
ex.printStackTrace();
|
}
|
}
|
return result.toString();
|
}
|
|
}
|
