关于java采用OKhttp的方式与C进行通信

亦凉 2021-07-09 10:51 230阅读 0赞

好久没有更新了，昨天遇到一个新的问题，正好更新下，首先介绍的我的业务逻辑，我的该部分功能，是我的java代码采用OKhttpp的方式向C那边的服务发送一个请求，让C去通过摄像机抓拍图片，存到服务器中，返回给我一个地址，我根据返回的地址去读取数据库中的图片地址获取服务器中的图片。

首先我java这边会封装好一个字符串

/**
         * 发送http请求给服务端获取图片
         * @param deviceId （摄像机Id）
         */
        public String catchPic(Long deviceId) {
            String uuid = UUID.randomUUID().toString().replace("-", "");
    
            VideoService vs = new VideoService();
            //唯一标识
            vs.setSn(uuid);
            //任务ID
            vs.setTaskid("10000");  
            //插入摄像机id和0，设备和诊断项列表
            List<CameraDiagitem> deviceList = new ArrayList<>();
            CameraDiagitem cameraDiagitem = new CameraDiagitem();
            cameraDiagitem.setCamera(deviceId.toString());//摄像机ID为String类型
            cameraDiagitem.setDiagitem("0");//9表示摄像机诊断，0表示摄像机抓图
            deviceList.add(cameraDiagitem);
            vs.setDevicelist(deviceList);
        }

当然要分装的属性和字段当然是你和C那边沟通好的，我的主要是封装了两层一边是VS里面的属性，另一边还有的devicelist 里面也有许多数据，封装好后全部添加到我的vs实体中。

第二部将封装好的vs转成json格式

String newvs = JacksonUtil.toJSon(vs);

然后对C那边进行第一次请求：

//第一次请求获取taskid
                String result = HttpUtil.sendPost3(SERVICE_URL, newvs);        
                System.out.println("result========="+result);
                JSONObject jsonObject = new JSONObject(result);

这里是我的http工具类请求：

/**
     * @author dcx
     *
     */
    public class HttpUtil {
    
        public static String sendGet(String url) throws IOException {
            OkHttpClient client = new OkHttpClient();//创建OkHttpClient对象
            client.setConnectTimeout(3, TimeUnit.SECONDS);
            Request request = new Request.Builder().url(url).build();//请求接口。如果需要传参拼接到接口后面。
            Response response = client.newCall(request).execute();//得到Response 对象
    
            if (!response.isSuccessful()){
                throw new IOException("get请求服务器端错误: " + response);
            }
            return response.body().string();
        }
    
        /**
         * 
         * 方法介绍:  Post提交表单
         * 
         */
        public static String sendPost(String url, Map<String, Object> param) throws IOException {
            OkHttpClient client = new OkHttpClient();//创建OkHttpClient对象。
            client.setConnectTimeout(3, TimeUnit.SECONDS);//设置超时时间
            FormEncodingBuilder formEncodingBuilder = new FormEncodingBuilder();  //创建表单提交实体，模拟 HTML 中的表单提交
            for (Map.Entry<String, Object> entry: param.entrySet()){
                formEncodingBuilder.add(entry.getKey(), entry.getValue().toString());  //获取表单的键值对
            }
            
            RequestBody formBody = formEncodingBuilder.build();  //创建表单请求体，
            
            Request request = new Request                     //创建Request 对象。
    					        		.Builder()
    					        		.url(url)
    					        		.post(formBody)        //传递请求体
    					        		.build();
    
            
            Response response = client.newCall(request).execute();
            if (!response.isSuccessful()) {
                throw new IOException("服务器端错误: " + response);
            }
    
            return response.body().string();  
        }
        
        
        /**
         * 
         * 方法介绍:  Post提交json格式
         * 
         */
        public static String sendPost3(String url, String param) throws IOException {
            OkHttpClient client = new OkHttpClient();//创建OkHttpClient对象。
            client.setConnectTimeout(3, TimeUnit.SECONDS);//设置超时时间
            
    
            //JSONObject paramJson = new JSONObject();//新建一个json字符串用来存放json数据
            
            System.out.println("第一次post请求");
            //MediaType  设置Content-Type 标头中包含的媒体类型值
            RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8")
            , param);
    
             Request request = new Request.Builder()
                    .url(url)//请求的url
                    .post(requestBody)
                    .build();   
            Response response = client.newCall(request).execute();
            if (!response.isSuccessful()) {
                throw new IOException("服务器端错误: " + response);
            }
    
            return response.body().string();  
        }
        
        /**
         * 
         * @date 2018年7月30日 
         * @param url
         * @return
         * @throws IOException
         */
        public static String sendGet2(String url) throws IOException {
        	System.out.println("---------get请求");
            OkHttpClient client = new OkHttpClient();//创建OkHttpClient对象
            client.setConnectTimeout(3, TimeUnit.SECONDS);
            Request request = new Request.Builder().url(url).build();//请求接口。如果需要传参拼接到接口后面。
            Response response = client.newCall(request).execute();//得到Response 对象
    
            if (!response.isSuccessful()){
                throw new IOException("get请求服务器端错误: " + response);
            }
            return response.body().string();
        }
        
        
    
    }

第一次请求回来后的数据也进行json格式处理：

JSONObject jsonObject = new JSONObject(result);

从中取出我需要的字段，拼接成新的字段后，然后第二次不断向C发送请求，因为抓拍图片需要时间，我就不断请求，直到我的请求字段发生变化，说明我已经请求到了图片的路径了，最后返回路径，到数据库中去查询。

//获取taskid
                String task_id = jsonObject.getString("task_id");
        		Boolean flg = false;
        		int count = 0;
    			String  url= SERVICE_URL+ "/"+task_id;
    			
    			System.out.println("---------第二次请求路径是:"+url);
    			String pic = null;
    			JSONArray lasturl = null;
        		while(true) {
        			try {
        				Thread.sleep(1 * 1000); //设置暂停的时间 5 秒
        				count ++ ;		
        				
        				String reg = HttpUtil.sendGet2(url);    				
        				System.out.println("<<<<<<<<<<<"+reg);
        				
        				JSONObject jsonObject2 = new JSONObject(reg);
        				int num = jsonObject2.getInt("return_code");//获取判断标志
        				
        				if (num==0) {
        					System.out.println("<<<<0<<<<<<<"+jsonObject2);
        					lasturl = jsonObject2.getJSONArray("pic");
        					int cnt = lasturl.length();
        					for (int i = 0; i < cnt; i++) {
        						JSONObject item = lasturl.getJSONObject(i);
        						long value = item.getLong("camera_id");
        						if (value == deviceId) {
    								pic = item.getString("item");
    								System.out.println("<<<<OK<<<<<<<"+pic);
    								break;
    							}
    						}
        					break;
    					}
        				else if (num<0) {
        					System.out.println("<<<<error<<<<<<<"+jsonObject2);
        					break;
    					}
         				else if (num>0) {
        					System.out.println("<<<<running<<<<<<<"+jsonObject2);
    					}
        				
    
        			} catch (InterruptedException e) {
        				e.printStackTrace();
        			}  
        		}
        		System.out.println("跳出循环结束");
                
                
                
                //System.out.println("文件全部路径为"+SERVICE_IMAGE+ jsonObject.getString("pic"));
                
        		System.out.println("返回路径是："+SERVICE_IMAGE+"/"+pic);
                return SERVICE_IMAGE+"/"+pic;
            } catch (Exception e) {
                logger.error("发送http请求给服务端获取图片出错，deviceId = " + deviceId + "---" + SERVICE_URL);
                throw new BusinessException("发送http请求给服务端获取图片出错");
            }