HttpClient远程调用基本使用(详解)

柔情只为你懂 2024-04-01 16:45 114阅读 0赞

## 通过HttpClient实现远程调用 ##

如果在不同的服务要实现服务与服务之间的调用，有众多选择，如**Httpclient**，**Okhttp**，**HttpURLConnection**，**RestTemplate**这几种，当然还有那些封装好的框架，如feign等。这里主要讲解一下这个HttpClient的使用。

### 1，通过get方式实现 ###

public static String get(String url,String tokenName,String tokenValue,Map<String,String> map) {
        
    	//构建客户端对象
    	CloseableHttpClient httpClient = HttpClientBuilder.create().build();
    	//设置参数
    	if (CollectionUtils.isNotEmpty(map)) {
        
    		//添加参数
    		String paramData = addParamByGet(map);
    		//拼接参数
    		url = url + "?" + paramData ;
    	}
    	//String url = ""http://127.0.0.1:8080/user"
    	HttpGet httpGet = new HttpGet(url);
    	//响应体
    	CloseableHttpResponse response;
    	try {
        
    		//添加请求头,添加token
    		//httpGet.addHeader("token", "eyJ0eXAiOiJKc29uV2ViVG9rZW4iLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOi");
    		httpGet.addHeader(tokenName, tokenValue);
    		//添加请求配置，设置响应时间等
    		RequestConfig requestConfig = RequestConfig.custom()
    			.setSocketTimeout(2000) //服务器响应超时时间
    			.setConnectionRequestTimeout(2000) //连接服务器超时时间
    			.build();
    
    		//将配置信息添加到 httpGet 中
    		httpGet.setConfig(requestConfig);
    		//调用接口，获取响应
    		response = httpClient.execute(httpGet);
    		//将响应转化为一个结果集
    		HttpEntity entity = response.getEntity();
    		//将内容转化为字符串，并且设定指定字符集
    		String result= EntityUtils.toString(entity, "UTF-8");
    		//最终将结果集返回
    		return result;
    	} catch (IOException e) {
        
    		e.printStackTrace();
    	} finally {
        
    		//资源释放
    		if (httpGet != null) {
        
    			try {
        
    				httpGet.clone();
    			} catch (CloneNotSupportedException e) {
        
    				e.printStackTrace();
    			}
    		}
    		if (httpClient != null) {
        
    			try {
        
    				httpClient.close();
    			} catch (IOException e) {
        
    				e.printStackTrace();
    			}
    		}
    	}
    }

get请求添加参数

/**
         * get添加参数
         */
        public static StringBuilder addParamByGet(Map<String,String> map){
        
            StringBuilder param = new StringBuilder();
            //遍历参数
            for (Map.Entry<String, String> m :map.entrySet()) {
        
                param.append(m.getKey()).append("=").append(m.getValue()).append("&");
            }
            return param;
        }

### 2，通过post的方式实现 ###

里面有一些token，参数之类的，如果不用，直接将代码注释即可

public static String post(String url, String tokenName,String tokenValue, Map<String,String> map) throws IOException {
        
    	//构建客户端对象
    	CloseableHttpClient httpClient = HttpClientBuilder.create().build();
    	CloseableHttpResponse response = null;
    	try {
        
    		//创建http post请求对象 这个url可以手动封装一个
    		HttpPost post = new HttpPost("http://127.0.0.1:8080/user/addUser");
    		//设置请求头
    		//post.setHeader("token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ1c2VyIiwidXN" +
    		//	"lckluZm8iOnsidXNlcklkIjoxNTg5ODIxMzMwNTY1NjQ0Mjg5fSwiZXhwIjoxNjY4MDU5MzQ3LCJpYXQiOjE2N" +
    		//	"jc5NzI5NDd9.mcmgzc0yEyTyfeo-2D5vpaYhdyD9LFBwCwP8s30r0Hs");
    		post.addHeader(tokenName, tokenValue);
    		//设置文本类型
    		post.setHeader("Content-Type", "application/json");
    
            //如果只有一两个参数的话，也可以通过这个反转义字符手动传参变成json格式，反正最终是要转成json的形式的
    		//post.setEntity(new StringEntity("{\"type\":\"1\"}", "UTF-8"));
           
    		//构建参数
            if (CollectionUtils.isNotEmpty(map)){
        
                JSONObject jo = new JSONObject();
                //增加参数
                addParam(map,jo);
    			post.setEntity(new StringEntity(jo.toString(), ContentType.APPLICATION_JSON));
            }else {
        
            	post.setEntity(new StringEntity(null, ContentType.APPLICATION_JSON));
            }
    		
            //创建响应对象
    		response = httpClient.execute(post);
    		/**
    		 * 由于响应接口返回的是一个字符串,因此需要转换
    		 * 响应体数据封装在HttpEntity对象中
    		 */
    		String result = EntityUtils.toString(response.getEntity(), "utf-8");
    		return result;
    	} catch (Exception e) {
        
    		e.printStackTrace();
    	} finally {
        
    		//关闭资源
    		response.close();
    		httpClient.close();
    	}
    }

post请求添加参数

/**
     * post添加参数
     */
    public static JSONObject addParam(Map < String, String > map, JSONObject jsonObject) {
        
    	for (Map.Entry < String, String > entry: map.entrySet()) {
        
    		jsonObject.put(entry.getKey(), entry.getValue());
    	}
    	return jsonObject;
    }

### 3，解析返回数据 ###

上面两种方式都是返回一个json格式的字符串，因此可以将这个字符串解析，或者直接在方法里面解析，我这里选择在外面解析

public static vois mian(String Args[]) {
        
    	//调用get请求，可以将里面的url，token等作为参数传入
    	String url = "localhost:8080/user/message";
    	String tokenName = "token";
    	String tokenValue = "xxx";
    	String message = get(url,tokenName,tokenValue,null);
    	//如果里面有多条数据，那么可以用数组方式解析,即使一条数据，也是可以通过这个解析的
    	JSONArray jsonArray = JSONArray.parseArray(message);
    	//遍历
        List<User> list = new ArrayList<>();
    	jsonArray.stream().forEach(json - > {
        
    		JSONObject jsonObject = JSONArray.parseObject(json.toString());
            User user = JSON.toJavaObject(jsonObject, User.class);
            list.add(user);
    	});
        //遍历全部的用户
        list.stream.forEach(e->{
        System.out.println(e)});
    }