HttpClient

以你之姓@ 2022-07-12 06:49 126阅读 0赞

public class RestClientUtil
    {
    	public static final int NUMBER_OF_TIMEOUT = 30000;
    	public static final int NUMBER_OF_100 = 100;
    
    	static Properties properties = new Properties();
    	static
    	{
    		InputStream stream = null;
    		try
    		{
    			// RestClientUtil.class.getClassLoader()
    			stream = Thread.currentThread().getContextClassLoader().getResourceAsStream("spring-config.properties");
    			properties.load(stream);
    		}
    		catch (Exception e)
    		{
    			e.printStackTrace();
    		}
    		finally
    		{
    			try
    			{
    				if (null != stream)
    				{
    					stream.close();
    				}
    			}
    			catch (Exception e)
    			{
    				e.printStackTrace();
    			}
    		}
    	}
    
    	public static String getValue(String key)
    	{
    		String value = properties.getProperty(key);
    		if (null == value)
    		{
    			return "";
    		}
    		return value;
    	}
    
    	public static String getPcServiceIP()
    	{
    		String pcServiceIP = properties.getProperty("pcServiceIP");
    		if (null == pcServiceIP)
    		{
    			return "";
    		}
    		return pcServiceIP;
    	}
    
    	public static String httpPost(String url, String requestParamJson)
    	{
    		try
    		{
    			HttpClient httpClient = new HttpClient();
    			HttpConnectionManagerParams managerParams = httpClient.getHttpConnectionManager().getParams();
    			// 设置连接超时时间(单位毫秒)
    			managerParams.setConnectionTimeout(NUMBER_OF_TIMEOUT);
    			// 设置读数据超时时间(单位毫秒)
    			managerParams.setSoTimeout(NUMBER_OF_TIMEOUT);
    
    			RequestEntity reqEntity = new StringRequestEntity(requestParamJson, "application/json", "UTF-8");
    			PostMethod post = new PostMethod(url);
    			post.setRequestEntity(reqEntity);
    			post.addRequestHeader("Content-Type", "application/json;charset=UTF-8");
    
    			HttpMethodParams params = new HttpMethodParams();
    			params.setContentCharset("UTF-8");
    			post.setParams(params);
    
    			httpClient.executeMethod(post);
    			InputStream is = post.getResponseBodyAsStream();
    			if (null == is)
    			{
    				return "";
    			}
    			BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
    			String tempbf;
    			StringBuffer buffer = new StringBuffer(NUMBER_OF_100);
    			while ((tempbf = br.readLine()) != null)
    			{
    				buffer.append(tempbf);
    			}
    
    			String responseJson = buffer.toString();
    
    			// System.out.println("responseJson: " + responseJson);
    			return responseJson;
    		}
    		catch (Exception e)
    		{
    			e.printStackTrace();
    		}
    		return "";
    
    	}
    
    	public static String invokeServcie(String serviceIP, Map<String, String> paramsMap)
    	{
    		try
    		{
    			// Client client = Client.create();
    			// URI u = new URI(serviceIP);
    			//
    			// WebResource resource = client.resource(u);
    			//
    			// MultivaluedMap<String, String> queryParams = new
    			// MultivaluedMapImpl();
    			//
    			// Set<String> keySet = paramsMap.keySet();
    			// for (Iterator<String> iterator = keySet.iterator();
    			// iterator.hasNext();)
    			// {
    			// String key = iterator.next();
    			// String value = paramsMap.get(key);
    			// queryParams.add(key, value);
    			// }
    			//
    			// String result =
    			// resource.queryParams(queryParams).get(String.class);
    			return "";
    		}
    		catch (Exception e)
    		{
    			e.printStackTrace();
    			return "";
    		}
    	}