java对接第三方接口的三种实现方式

2025-05-24 03:50

本文主要是介绍java对接第三方接口的三种实现方式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《java对接第三方接口的三种实现方式》:本文主要介绍java对接第三方接口的三种实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教...

在日常工作中,经常需要跟第三方系统对接,我们做为客户端,调用他们的接口进行业务处理

常用的几种调用方式有:

  • 1.原生的Java.net.HttpURLConnection(jdk);
  • 2.再次封装的HttpClient、CloseableHttpClient(Apache);
  • 3.Spring提供的RestTemplate;

当然还有其他工具类进行封装的接口,比如hutool的HttpUtil工具类,里面除了post、get请求外,还有下载文China编程件的方法downloadFile等。

HttpURLConnection调用方法

HTTP正文的内容是通过OutputStream流写入,向流中写入的数据不会立即发送到网络,而是存在于内存缓冲区中,待流关闭时,根据写入的内容生成HTTP正文。

调用getInputStream()方法时,会返回一个输入流,用于从中读取服务器对于HTTP请求的返回报文

@Slf4j
public class HttpURLConnectionUtil {
   /**
     *
     * Description: 发送http请求发送post和json格式
     * @param url      	请求URL
     * @param params    json格式的请求参数
     */
    public static String doPost(String url, String params) throws Exception {

        OutputStreamWriter out = null;
        BufferedReader reader = null;
        StringBuffer response = new StringBuffer();
        URL httpUrl = null; // HTTP URL类 用这个类来创建连接
        try {
            // 创建URL
            httpUrl = new URL(url);
            log.info("--------发起Http Post 请求 ------------- url:" + url + "---------params:" + params);

            // 建立连接
            HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
            //设置请求的方法为"POST",默认是GET
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setRequestProperty("connection", "keep-alive");
            conn.setUseCaches(false);// 设置不要缓存
            conn.setInstanceFollowRedirects(true);
            //由于URLConnection在默认的情况下不允许输出,所以在请求输出流之前必须调用setDoOutput(true)
            conn.setDoOutput(true);
            // 设置是否从httpUrlConnection读入
            conn.setDoInput(true);
            //设置超时时间
            conn.setConnectTimeout(30000);
            conn.setReadTimeout(30000);
            conn.connect();
            // POST请求
            out = new OutputStreamWriter(conn.getOutputStream());
            out.write(params);
            out.flush();
            // 读取响应
            reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));
            String lines;
            while ((lines = reader.readLine()) != null) {
                response.append(lines);
            }
            reader.close();
            // 断开连接
            conn.disconnect();
        } catch (Exception e) {
            log.error("--------发起Http Post 请求 异常 {}-------------", e);
            throw new Exception(e);
        }
        // 使用finally块来关闭输出流、输入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (reader != null) {
                    reader.close();
                }
            } catch (IOException ex) {
                log.error(String.valueOf(ex));
            }
        }
        return response.toString();
    }
}

CloseableHttpClient调用

CloseableHttpClient 是一个抽象类,实现了httpClient接口,也实现了java.io.Closeable;

支持连接池管理,可复用已建立的连接 PoolingHttpClientConnectionManager

通过 httpClient.close() 自动管理连接释放

支持HTTPS访问 HttpHost proxy = new HttpHost(“127.0.0.1”, 8080, “http”);

@Slf4j
public class CloseableHttpClientUtil {
	/**
	*url 第三方接口地址
	*json 传入的报文体,可以是dto对象,string、json等
	*header 额外传入的请求头参数
	*/	
  public static String doPost(String url, Object json,Map<String,String> header) {

        CloseableHttpClient httpclient = HttpClientBuilder.create().build();
        HttpPost httpPost= new HttpPost(url);//post请求类型
        String result="";//返回结果
        String requestJson="";//发送报文体
        try {
        	requestJson=JSONObject.toJSONString(json);
            log.info("发送地址:"+url+"发送报文:"+requestJson);
            //StringEntity s = new StringEntity(requestJson, Charset.forName("UTF-8"));
            StringEntity s= new StringEntity(requestJson, "UTF-8");
       		// post请求是将参数放在请求体里面传过去的;这里将entity放入post请求体中
       		httpPost.setHeader("Content-Type", "application/json;charseChina编程t=utf8");
            httpPost.setEntity(s);
            if(header!=null){
                Set<String> strings = header.keySet();
                for(String str:strings){
                    httpPost.setHeader(str,header.get(str));
                }
            }
            HttpResponse res = httpclient.execute(httpPost);
            if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                    result = EntityUtils.toString编程(res.getEntity());
                    //也可以把返回的报文转成json类型
                    // JSONObject  response = JSONObject.parseobject(result);
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        finally {
     		//此处可以加入记录日志的方法
            // 关闭连接,释放资源
           if (httpclient!= null){
                try {
                    httpclient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    }
        return result;
    }
}

RestTemplate调用

//可以在项目启动类中添加RestTemplate 的bean,后续就可以在代码中@Autowired引入。
@Bean
public RestTemplate restTemplate() {
return new RestTemplatwww.chinasem.cne();
}
@Slf4j
@Component
public class RestTemplateUtils {
	@Autowired
	private RestTemplate restTemplate;

	/**
	 * get 请求 参数在url后面  http://xxxx?aa=xxx&page=0&size=10";
	 * @param urls 
	 * @return string
	 */
	public String doGetRequest(String urls) {
		
		URI uri = UriComponentsBuilder.fromUriString(urls).build().toUri();
		log.info("请求接口:{}", urls);
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(MediaType.APPLICATION_JSON);
		HttpEntity<String> httpEntity = new HttpEntity<>(headers);
		//通用的方法exchange,这个方法需要你在调用的时候去指定请求类型,可以是get,post,也能是其它类型的请求
		ResponseEntity<String> responseEntity = restTemplate.exchange(uri, HttpMethod.GET, httpEntity, String.class);
		if (responseEntity == null) {
			return null;
		}
     android   log.info("返回报文:{}", JSON.toJSONString(responseEntity));
		
		return responseEntity.getBody();
	}
	
	/**
	 * post 请求 参数在 request里;
	 * @param url, request
	 * @return string
	 */
	public String doPostRequest(String url, Object request){
		URI uri = UriComponentsBuilder.fromUriString(url).build().toUri();

		String requestStr= JSONObject.toJSONString(request);
		log.info("请求接口:{}, 请求报文:{}", url, requestStr);
		HttpHeaders headers = new HttpHeaders();	
		headers.setContentType(MediaType.APPLICATION_JSON);
		HttpEntity<String> httpEntity = new HttpEntity<>(requestStr, headers);
		ResponseEntity<String> responseEntity = restTemplate.exchange(uri, HttpMethod.POST, httpEntity, String.class);
				
		if (responseEntity == null) {
			return null;
		}
		
		String seqResult = "";
		try {
			if(responseEntity.getBody() != null ) {		
				if(responseEntity.getBody().contains("9001")) {
					seqResult = new String(responseEntity.getBody().getBytes("ISO8859-1"),"utf-8");
				}else {
					seqResult = new String(responseEntity.getBody().getBytes(),"utf-8");	
				}											
			}
			
			log.info("返回报文:{}", seqResult);
			
		} catch (UnsupportedEncodingException e) {
			log.error("接口返回异常", e);
		}

		return seqResult;
	}
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程China编程(www.chinasem.cn)。

这篇关于java对接第三方接口的三种实现方式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1154755

相关文章

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

一文详解SpringBoot中控制器的动态注册与卸载

《一文详解SpringBoot中控制器的动态注册与卸载》在项目开发中,通过动态注册和卸载控制器功能,可以根据业务场景和项目需要实现功能的动态增加、删除,提高系统的灵活性和可扩展性,下面我们就来看看Sp... 目录项目结构1. 创建 Spring Boot 启动类2. 创建一个测试控制器3. 创建动态控制器注

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表(即列表中包含列表)转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach

C#读写文本文件的多种方式详解

《C#读写文本文件的多种方式详解》这篇文章主要为大家详细介绍了C#中各种常用的文件读写方式,包括文本文件,二进制文件、CSV文件、JSON文件等,有需要的小伙伴可以参考一下... 目录一、文本文件读写1. 使用 File 类的静态方法2. 使用 StreamReader 和 StreamWriter二、二进

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu