java通过java.net.URL发送http请求调用.net写的webService接口

一时失言乱红尘 2022-04-15 00:58 562阅读 0赞

系统是用 java写的，但需要调用同事用.net写的一个webService接口。

所以记录下java如何调用其他不同语言的接口的。

代码：

用到的工具类HttpUtil ：

package cn.com.comit.appointment.modules.wechat.utils;
    
    import java.io.BufferedReader;
    import java.io.ByteArrayOutputStream;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.HttpURLConnection;
    import java.net.URL;
    
    /**
     * http工具
     *
     */
    public final class HttpUtil {
        /**
         * 模拟http协议发送get请求
         **/
        public static String sendGetRequest(String url) {
            String result = "";
            InputStream in = null;
            
                HttpURLConnection connection=null;
                try{
                    URL httpUrl = new URL(url);
                    connection = (HttpURLConnection) httpUrl.openConnection();
                    connection.setRequestProperty("accept", "*/*");
                    connection.setRequestProperty("Charset", "UTF-8");
                    connection.setRequestProperty("connection", "Keep-Alive");
                    connection.setRequestProperty("user-agent","Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                    connection.setRequestMethod("GET");
                    connection.connect();
                    if (connection.getResponseCode() == 200) {
                        in = connection.getInputStream();
                        ByteArrayOutputStream bs=new ByteArrayOutputStream();
                        int n=0;
                        byte[] datas=new byte[2048];
                        while((n=in.read(datas))!=-1){
                            bs.write(datas, 0,n);
                        }
                        bs.flush();
                        result=new String(bs.toByteArray(),"utf-8");
                    }
                }catch(Exception ex){
                    ex.printStackTrace();
                }finally{
                    try{
                        if (in != null){
                            in.close();
                        }
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                    try{connection.disconnect();}catch(Exception ex){}
                }
            return result;
        }/**
         * 模拟http协议发送post请求
         **/
        public static String sendPostRequest(String url, String param) {
            InputStream in = null;
            String result = "";
            HttpURLConnection connection=null;
            try{
                URL httpUrl = new URL(url);
                connection = (HttpURLConnection) httpUrl.openConnection();
                connection.setRequestProperty("accept", "*/*");
                connection.setRequestProperty("Charset", "UTF-8");
                connection.setRequestProperty("connection", "Keep-Alive");
                connection.setRequestProperty("user-agent","Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                connection.setRequestMethod("POST");
                connection.setDoOutput(true);
                connection.setDoInput(true);
                connection.setUseCaches(false);
                connection.getOutputStream().write(param.getBytes("utf-8"));
                connection.getOutputStream().flush();
                if (connection.getResponseCode() == 200){
                    in = connection.getInputStream();
                    ByteArrayOutputStream bs=new ByteArrayOutputStream();
                    int n=0;
                    byte[] datas=new byte[2048];
                    while((n=in.read(datas))!=-1){
                        bs.write(datas, 0,n);
                    }
                    bs.flush();
                    result=new String(bs.toByteArray(),"utf-8");
                }
            }catch(Exception ex){
                ex.printStackTrace();
            }finally {
                try {
                    if (in != null) {
                        in.close();
                    }
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
                try{connection.disconnect();}catch(Exception ex){}
            }
            return result;
        }
    
        /**
         * 普通post文件上传
         */
        public static String upLoadAttachment(String url, File file){
            String result = null;
            
                HttpURLConnection connection=null;
                BufferedReader reader = null;
                try{
                    URL httpUrl = new URL(url);
                    connection = (HttpURLConnection) httpUrl.openConnection();
                    connection.setRequestProperty("accept", "*/*");
                    connection.setRequestProperty("Charset", "UTF-8");
                    connection.setRequestProperty("connection", "Keep-Alive");
                    connection.setRequestProperty("user-agent","Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                    connection.setRequestMethod("POST");
                    connection.setDoOutput(true);
                    connection.setDoInput(true);
                    connection.setUseCaches(false);
                    String bound = "----------" + System.currentTimeMillis();
                    connection.setRequestProperty("Content-Type","multipart/form-data; boundary="+bound);
                    StringBuilder sb = new StringBuilder();
                    sb.append("--");
                    sb.append(bound);
                    sb.append("\r\n");
                    sb.append("Content-Disposition: form-data;name=\"media\";filename=\""+ file.getName()+"\"\r\n");
                    sb.append("Content-Type:application/octet-stream\r\n\r\n");
                    byte[] head = sb.toString().getBytes("utf-8");
                    OutputStream out = new DataOutputStream(connection.getOutputStream());
                    out.write(head);
                    DataInputStream in = new DataInputStream(new FileInputStream(file));
                    int bytes = 0;
                    byte[] bufferOut = new byte[1024];
                    while ((bytes = in.read(bufferOut)) != -1) {
                        out.write(bufferOut, 0, bytes);
                    }
                    in.close();
                    byte[] foot = ("\r\n--" + bound + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线
                    out.write(foot);
                    out.flush();
                    out.close();
                    InputStream inn = connection.getInputStream();
                    ByteArrayOutputStream bs=new ByteArrayOutputStream();
                    int n=0;
                    byte[] datas=new byte[2048];
                    while((n=inn.read(datas))!=-1){
                        bs.write(datas, 0,n);
                    }
                    bs.flush();
                    result=new String(bs.toByteArray(),"utf-8");
                    return result;
                }catch(Exception ex){
                    ex.printStackTrace();
                }finally {
                    try{connection.disconnect();}catch(Exception ex){}
                }
            return null;
        }
    
    }

用到的加密类DESEncryption ：（因为同事那边的接口需要加密和解密）

package cn.com.comit.appointment.modules.wechat.test.msg;
    
    import java.net.URLDecoder;
    import java.net.URLEncoder;
    import javax.crypto.Cipher;
    import javax.crypto.SecretKey;
    import javax.crypto.SecretKeyFactory;
    import javax.crypto.spec.DESKeySpec;
    import javax.crypto.spec.IvParameterSpec;
    
    /**
     * 加解密
     * @author admin
     *
     */
    public class DESEncryption {
    
        //密钥设置,可根据服务器传过来的密钥设置。达到动态的效果。
        private String secret_key = "密钥";
          
        //加密数据
        public static byte[] encrypt(String message, String key) throws Exception {
            Cipher cipher = Cipher.getInstance("DES/CBC/PKCS5Padding");
            DESKeySpec desKeySpec = new DESKeySpec(key.getBytes("UTF-8"));
            SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("DES");
            SecretKey secretKey = keyFactory.generateSecret(desKeySpec);
            IvParameterSpec iv = new IvParameterSpec(key.getBytes("UTF-8"));
            cipher.init(Cipher.ENCRYPT_MODE, secretKey, iv);
            return cipher.doFinal(message.getBytes("UTF-8"));
        }
    
        public static String toHexString(byte b[]) {
            StringBuffer hexString = new StringBuffer();
            for (int i = 0; i < b.length; i++) {
                String plainText = Integer.toHexString(0xff & b[i]);
                if (plainText.length() < 2)
                    plainText = "0" + plainText;
                hexString.append(plainText);
            }
            return hexString.toString();
        }
    	
    	//带密钥加密方法调用
        public  String DESEncrypt(String msg) {
            String encryt_data;
            String encryt_code;
            try {
                encryt_data = URLEncoder.encode(msg, "utf-8").toLowerCase();
                encryt_code = toHexString(encrypt(encryt_data, secret_key)).toUpperCase();
                return encryt_code;
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
    }

实现类：因为返回的是json数组格式数据：“【\{“x”:"x"\}】”；所以需要把其转换为json对象

package cn.com.comit.appointment.modules.wechat.utils;
    
    import java.util.Date;
    
    import cn.com.comit.appointment.common.utils.DateUtils;
    import cn.com.comit.appointment.modules.wechat.test.msg.DESEncryption;
    import net.sf.json.JSONObject;
    
    /**
     * 发送查找条件获取数据
     * 
     *
     */
    public class SendSearchUtil {
    	
    	public static void  main(String[] args){
    		
    		JSONObject  json=sendSearch("xx","xx","xx");
    	}
    	
    	
    	public static JSONObject sendSearch(String CaseType,String CarId,String TransgressTime){
    		try {
    		StringBuffer sb=new StringBuffer("{");
    		sb.append("\"CaseType\":"+"\""+CaseType+"\"}_TE_");
    		sb.append("{\"CarId\":"+"\""+CarId+"\"}_TE_");
    		sb.append("{\"TransgressTime\":"+"\""+TransgressTime+"\"}_TE_");
    		String key = DESEncryption.toHexString(DESEncryption.encrypt(DateUtils.formatDateTime(new Date()),"密钥"));
    			sb.append(key);
    			System.out.println("sb---->"+sb.toString());
    			//调用案件查询接口，解析返回的json数据
    			String url="接口地址/服务.svc/方法名";
    			String params=sb.toString();
    			String msg=HttpUtil.sendPostRequest(url,params);
    			System.out.println("msg---->"+msg);
    			 String s1=msg.replace("\\","");
    		    String s2 =s1.replace("[","");
                String s3 =s2.replace("]", "");
    			String json=s4.substring(1, s4.length()-1);
    			 net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(json);
    			 System.out.println("jsonObject--->"+jsonObject.containsKey("CaseNumber"));
    			 return jsonObject;
    		} catch (Exception e) {
    			System.out.println("e---"+e.getMessage());
    			e.printStackTrace();
    		}
    		
    		return null;
    		
    	}
    	
    }

最后成功获取到数据！

### 我的座右铭：不会，我可以学；落后，我可以追赶；跌倒，我可以站起来；我一定行。 ###