Java如何远程调用对方接口

 更新时间:2024年05月13日 09:46:22   作者:太公姜子牙  
这篇文章主要介绍了Java如何远程调用对方接口问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

Java远程调用对方接口

在实际的项目开发中,经常需要调用远程接口,那java是如何实现调用远程接口的呢?这里主要介绍java调用远程接口的两种方式:

一、调用远程http接口

通过jdk的网络类Java.net.HttpURLConnection调用第三方http接口

/**
     * @Auther 	kezf
     * @Date 	2020/4/11
     * @param urlStr  	目标地址
     * @param json     	请求参数
     * @param charset  	编码
     * @return
     */
public static String doPost(String urlStr,String json,String charset) {
        String result = null;
        System.out.println("请求参数:"+json);
        try {
            //获取目标地址
            URL url = new URL(urlStr);
            //创建连接
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            //设置向HttpURLConnection输出、输入(发送数据、接收数据),当请求为post时必须设置这两个参数
            connection.setDoOutput(true);        
            connection.setDoInput(true);
            //设置请求方式
            connection.setRequestMethod("POST");
            //设置是否开启缓存,post请求时,缓存必须关掉
            connection.setUseCaches(false);
            //设置连接是否自动处理重定向(setFollowRedirects:所用http连接;setInstanceFollowRedirects:本次连接)
            connection.setInstanceFollowRedirects(true);
            //设置提交内容类型
            connection.setRequestProperty("Content-Type","application/json");
            //开始连接
            connection.connect();
            //发送请求
            DataOutputStream out = new DataOutputStream(connection.getOutputStream());
            out.write(json.getBytes(charset));
            out.flush();
            out.close();
            //读取响应
            BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), charset));
            String lines;
            StringBuffer sb = new StringBuffer("");
            while ((lines = reader.readLine()) != null) {
                lines = new String(lines.getBytes());
                sb.append(lines);
            }
            result = sb.toString();
            System.out.println("请求返回结果:"+result);
            reader.close();
            // 断开连接
            connection.disconnect();
        } catch (MalformedURLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (UnsupportedEncodingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return result;
    }

二、调用远程Web Service 接口

使用axis的call方式调用

public String signConfirm(TpgDsfxyxx dsfxyqdxx){
		String result=null;
		try {
		    //创建服务
			Service service = new Service();
			//创建Call对象
			Call call = (Call) service.createCall();
			//设置服务所在的地址
			call.setTargetEndpointAddress(StringUtil.getGzfconfigValueByName("dsfxy_qd_url"));
			//设置调用方法名
			call.setOperation("SignConfirm");
			//添加请求参数
			call.addParameter("xyh", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("sqh", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("yzm", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("sfywzl", XMLType.XSD_INTEGER, ParameterMode.IN);
			call.addParameter("jldxhh", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("jldxhm", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("zjlx", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("zjhm", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("dhhm", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("dz", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("fkryhdm", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("fkrkhh", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("fkrzh", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("fkrmc", XMLType.XSD_STRING, ParameterMode.IN);
			call.addParameter("fkrlx", XMLType.XSD_INTEGER, ParameterMode.IN);
			call.setReturnType(XMLType.XSD_STRING);
			System.out.println(dsfxyqdxx.toString());
			//调用服务
			result = (String) call.invoke(new Object[]{String.valueOf(dsfxyqdxx.getId()), dsfxyqdxx.getSqh(), dsfxyqdxx.getYzm(),
					dsfxyqdxx.getSfywzl(), dsfxyqdxx.getJldxhh(), dsfxyqdxx.getJldxhm(), dsfxyqdxx.getZjlx(),
					dsfxyqdxx.getZjhm(), dsfxyqdxx.getDhhm(), dsfxyqdxx.getDz(), dsfxyqdxx.getFkryhdm(),
					dsfxyqdxx.getFkrkhh(), dsfxyqdxx.getFkrzh(), dsfxyqdxx.getFkrmc(), dsfxyqdxx.getFkrlx()});
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		System.out.println("signConfirm###:" + result);
		return result;
	}

三、http接口和web service 接口的区别

常见的API接口有两类:http接口和webservice接口。

  • http接口走http协议,通过路径来区分调用方法,请求报文一般是key-value形式的,返回报文一般是json串,常用的是get和post方法来请求。
  • webservice接口走的soap协议,通过http传输,请求报文和返回报文都是xml格式的

封装一个java调用远程接口工具类

java调用远程接口的工具类

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;

import com.alibaba.fastjson.JSONObject;

public class RemoteDemo {
	//远程调用接口
	/**
	 * 
	 * @param url:远程接口url
	 * @param timeout:连接超时时间
	 * @param object:如所需参数是json对象类型,先将参数封装成JSONObject类型
	 * @param method:发送方式:以post还是get
	 * @param contentType:指定HTTP的Content-Type类型
	 * @return	返回的是接口返回内容对应的json字符串
	 */
	public static String remoteJsonRequest(String url, int timeout, JSONObject object, String method, String contentType) {
        URL connect;
        StringBuffer data = new StringBuffer();
        try {
            connect = new URL(url);
            HttpURLConnection connection = (HttpURLConnection) connect.openConnection();
            connection.setRequestMethod(method);
            connection.setDoOutput(true);
            connection.setReadTimeout(timeout);
            connection.setRequestProperty("Content-Type", contentType);
            OutputStreamWriter paramout = new OutputStreamWriter(connection.getOutputStream(), "UTF-8");
            paramout.write(object.toString());
            paramout.flush();
            InputStream inputStream = connection.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "UTF-8");
            BufferedReader reader = new BufferedReader(inputStreamReader);

            String line;
            while ((line = reader.readLine()) != null) {
                data.append(line);
            }
            paramout.close();
            reader.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return data.toString();
    }
}

适用场景

开发过程中离不开直接通过后端访问某些接口来拿数据,比如需要和另外的平台进行数据的交互或者对接

我们就会去参考对方给的接口文档进行数据访问,这时就可以使用这个工具类,相对还是比较方便的

使用方法简述

  • 接口传参方式

接口所需的是普通键值对:直接跟在url后面进行传参,obj参数传一个空的JSONObject对象,Demo如下:

JSONObject obj = new JSONObject();
RemoteDemo.remoteJsonRequest("http://localhost:8080/xx/xx?k1=v1&k2=v2", 5000, obj,  "POST" ,"application/x-www-form-urlencoded");

接口所需的是json字符串:则将参数封装在JSONObject对象里面,Demo如下:

JSONObject obj = new JSONObject();
obj.put("k1", "v1");
obj.put("k2", "v2");
RemoteDemo.remoteJsonRequest("http://localhost:8080/xx/xx", 5000, obj, "POST", "application/json");

另外就是参数method和参数contentType,method是指定以post方式还是get方式访问请求,这里要求大写,传字符串"POST"或者"GET";contentType参数用来指定http对应的Content-Type内容,一般对应的接口文档会给出,这里我们也需要进行明确指定。

顺便聊一聊另一个参数JSONObject,可以很好的用来进行对象和json字符串的转换,通过导的包可以看出,使用的是阿里的;因为使用阿里的效率更高,运行速度更快;而且JSONObject这部分内容低版本有漏洞,所以需要使用尽可能高的版本。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • SpringCloud组件OpenFeign之默认HTTP请求方式详解

    SpringCloud组件OpenFeign之默认HTTP请求方式详解

    这篇文章主要介绍了SpringCloud组件OpenFeign之默认HTTP请求方式详解,在SpringMvcContract类中有个这样的方法processAnnotationOnMethod,见名思意,这个方法就是处理Feign接口下方法上的注解的,需要的朋友可以参考下
    2024-01-01
  • Java语言实现对MySql数据库中数据的增删改查操作的代码

    Java语言实现对MySql数据库中数据的增删改查操作的代码

    这篇文章主要介绍了Java语言实现对MySql数据库中数据的增删改查操作的代码,实现了连接数据库,和数据库的增删改查操作,有兴趣的可以了解一下。
    2016-12-12
  • Java中的WeakHashMap浅析

    Java中的WeakHashMap浅析

    这篇文章主要介绍了Java中的WeakHashMap浅析,weakhashmap关键是:当一个对象被GC回收时,响应的值对象的引用从map中删除,weakhashmap能节约存储空间,来实现缓存那些非必要的数据,需要的朋友可以参考下
    2023-09-09
  • RestTemplate发送HTTP GET请求使用方法详解

    RestTemplate发送HTTP GET请求使用方法详解

    这篇文章主要为大家介绍了关于RestTemplate发送HTTP GET请求的使用方法详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家<BR>33+多多进步
    2022-03-03
  • Spring线程池ThreadPoolTaskExecutor的用法及说明

    Spring线程池ThreadPoolTaskExecutor的用法及说明

    这篇文章主要介绍了Spring线程池ThreadPoolTaskExecutor的用法及说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • 浅谈Spring中@Transactional事务回滚及示例(附源码)

    浅谈Spring中@Transactional事务回滚及示例(附源码)

    本篇文章主要介绍了浅谈Spring中@Transactional事务回滚及示例(附源码),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-12-12
  • Spring中@Value注解的使用方法详解

    Spring中@Value注解的使用方法详解

    这篇文章主要介绍了Spring中@Value注解的使用方法详解,在spring项目中必不可少的就是读取配置文件,那么读取配置文件就有两种方式,一种就是使用Spring中@Value注解,还有一种是使用SpringBoot中的@ConfigurationProperties注解,需要的朋友可以参考下
    2024-01-01
  • 深入理解ThreadLocal工作原理及使用示例

    深入理解ThreadLocal工作原理及使用示例

    这篇文章主要介绍了深入理解ThreadLocal工作原理及使用示例,涉及ThreadLocal<T> 简介和使用示例及ThreadLocal<T>的原理等相关内容,具有一定参考价值,需要的朋友可以了解下。
    2017-11-11
  • Springboot中@Value的使用详解

    Springboot中@Value的使用详解

    这篇文章主要介绍了Springboot中@Value的使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • Ubuntu 安装 JDK8 的两种方法(总结)

    Ubuntu 安装 JDK8 的两种方法(总结)

    下面小编就为大家带来一篇Ubuntu 安装 JDK8 的两种方法(总结)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06

最新评论