基于IPv6的智能机器人园区异常情况监测系统

package com.example.saierclient.utils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.BufferedReader; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.security.SecureRandom; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.HashMap; import java.util.Map; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSession; import javax.net.ssl.SSLSocketFactory; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; import okhttp3.Call; import okhttp3.Callback; import okhttp3.FormBody; import okhttp3.MediaType; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.RequestBody; import okhttp3.Response; @SuppressWarnings("all") public class MyHttpClientUtils { private static Logger logger = LoggerFactory.getLogger(MyHttpClientUtils.class); private static String JSON = "application/json; charset=utf-8"; //private static String MEDIA_TYPE_JSON= "application/x-www-form-urlencoded; charset=utf-8"; /**使用volatile双重校验锁**/ private static volatile Semaphore semaphore = null; private static volatile OkHttpClient okHttpClient = null; /**建立单例模式*/ public static Semaphore getSemaphoreInstance(){ //只能0个线程同时访问 synchronized (MyHttpClientUtils.class) { if (semaphore == null) { semaphore = new Semaphore(0); } } return semaphore; } /**建立单例模式*/ public static OkHttpClient getInstance(){ synchronized (MyHttpClientUtils.class) { if (okHttpClient == null) { //这里是以毫秒为单位，1000 毫秒 = 1秒 okHttpClient = new OkHttpClient().newBuilder() .connectTimeout(5000, TimeUnit.SECONDS)// 设置超时时间 .readTimeout(5000, TimeUnit.SECONDS)// 设置读取超时时间 .writeTimeout(5000, TimeUnit.SECONDS)// 设置写入超时时间 .build(); } } return okHttpClient; } /** * @Description 求在子线程发起网络请求 * @param url 请求url地址 * @param params 请求body参数 * @param okHttpClientCall 回调接口 * @throws IOException 参数 * @return void 返回类型 */ public static void createAsycHttpGet(String url,Map<String,Object> params,String contentType,final IOkHttpClientCallBack okHttpClientCall) { // 创建请求对象 Call call = createCall(url, params); //发起异步的请求 call.enqueue(new Callback() { @Override public void onResponse(Call call, Response response) throws IOException { if (response!=null && response.isSuccessful()) { String string = response.body().string(); okHttpClientCall.onSuccessful(string); } } @Override public void onFailure(Call call, IOException e) { String errorLog = getCurrentClassName()+"#createHttpGet,请求异常，异常信息为:"+e.getMessage(); logger.error("@see "+errorLog); } }); } /** * @Description 求在子线程发起网络请求 * @param url 请求url地址 * @param params 请求body参数 * @param okHttpClientCall 回调接口 * @throws IOException 参数 * @return void 返回类型 */ public static String createAsycHttpGet(String url,Map<String,Object> params,String contentType) { final StringBuilder buffer = new StringBuilder(""); try { // 创建请求对象 Call call = createCall(url, params); //发起异步的请求 call.enqueue(new Callback() { @Override public void onResponse(Call call, Response response) throws IOException { if (response!=null && response.isSuccessful()) { String string = response.body().string(); buffer.append(string); getSemaphoreInstance().release(); } } @Override public void onFailure(Call call, IOException e) { String errorLog = getCurrentClassName()+"#createHttpGet,请求异常，异常信息为:"+e.getMessage(); logger.error("@see "+errorLog); } }); getSemaphoreInstance().acquire();//获取许可 return buffer.toString(); } catch (InterruptedException e) { e.printStackTrace(); } return buffer.toString(); } /** * @Description 求在子线程发起网络请求 * @param url 请求url地址 * @param params 请求body参数 * @param okHttpClientCall 回调接口 * @throws IOException 参数 * @return void 返回类型 */ public static String createHttpGet(String url,Map<String,Object> params,String contentType) { try { // 创建请求对象 Call call = createCall(url, params); Response response = call.execute(); // if (response!=null && response.isSuccessful() && ObjectUtil.isNotEmpty(response.body())) { if (response!=null && response.isSuccessful()) { //Collection<String> readLines = IOUtil.readLines(byteStream); //System.out.println(readLines); return convertToString(response.body().byteStream()); } } catch (IOException e) { e.printStackTrace(); } return ""; } /** * @Description convertStreamToString * @param is * @return 参数 * @return String 返回类型 * @throws */ public static String convertToString(InputStream is) { BufferedReader reader = new BufferedReader(new InputStreamReader(is)); StringBuilder buffer = new StringBuilder(); String line = null; try { while ((line = reader.readLine()) != null) { buffer.append(line + "\r"); } } catch (IOException e) { e.printStackTrace(); } finally { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } return buffer.toString(); } /** * @Description convertStr * @param is * @return * @throws IOException 参数 * @return String 返回类型 * @throws */ public static String convertStr(InputStream is) throws IOException { OutputStream baos = new ByteArrayOutputStream(); int i = -1; while ((i = is.read()) != -1) { baos.write(i); } return baos.toString(); } /** * @Description 创建异步表单Body参数的post请求处理 * @param url 请求链接 * @param params 请求表单body参数 * @param okHttpClientCall 参数 回调接口 * @return void 返回类型 */ public static void createPostByAsynWithForm(String url,Map<String,Object> params,final IOkHttpClientCallBack okHttpClientCall) { FormBody.Builder builder = new FormBody.Builder(); for (String key : params.keySet()) { builder.add(key, params.get(key).toString