余晖落尽暮晚霞,黄昏迟暮远山寻
本站
当前位置:网站首页 > 编程知识 > 正文

Java,HttpClient4 GET、POST调用及发送JSON,服务器Servlet实现

xiyangw 2022-11-24 16:41 39 浏览 0 评论

背景

本文章是为了快速学习,更深入的了解一些内容而设定,一般地,复制代码即可运行。

Java,HttpClient4 GET、POST调用及发送JSON,服务器Servlet实现

Apache HttpClient

HttpClient是Apache Jakarta Common下子项目,用来提供高效的、最新的、功能丰富的支持HTTP协议的客户端编程工具包,并且支持HTTP协议最新的版本和建议。

Java Servlet实现服务器端

参考: Maven创建Web项目,Servlet、JSP,配置Tomcat运行

处理普通GET、POST请求的Servlet

package com.what21.servlet;

import com.fasterxml.jackson.databind.ObjectMapper;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.*;

@WebServlet("/service/general")
public class GeneralHttpServlet extends HttpServlet {

    @Override
    protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("UTF-8");
        // 接收所有的header参数
        Enumeration<String> headerEnumer = request.getHeaderNames();
        System.out.println("-------------------------------------------------");
        while (headerEnumer.hasMoreElements()) {
            String name = headerEnumer.nextElement();
            System.out.println(name + ":" + request.getHeader(name));
        }
        System.out.println("-------------------------------------------------");
        Map<String, String[]> parameterMap = request.getParameterMap();
        Set<String> keySet = parameterMap.keySet();
        for (String key : keySet) {
            System.out.println(key + ":" + Arrays.toString(parameterMap.get(key)));
        }
        System.out.println("-------------------------------------------------");
        Map<String, Object> dataMap = new HashMap<>();
        dataMap.put("code", "ok");
        ObjectMapper mapper = new ObjectMapper();
        String json = mapper.writeValueAsString(dataMap);
        response.setContentType("text/json;charset=UTF-8");
        response.setCharacterEncoding("UTF-8");
        PrintWriter writer = response.getWriter();
        writer.print(json);
        writer.flush();
    }

}

处理普通POST JSON请求的Servlet

package com.what21.servlet;

import com.fasterxml.jackson.databind.ObjectMapper;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.util.*;

@WebServlet("/service/json")
public class PostJsonHttpServlet extends HttpServlet {

    @Override
    protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 接收所有的header参数
        Enumeration<String> headerEnumer = request.getHeaderNames();
        System.out.println("-------------------------------------------------");
        while (headerEnumer.hasMoreElements()) {
            String name = headerEnumer.nextElement();
            System.out.println(name + ":" + request.getHeader(name));
        }
        System.out.println("-------------------------------------------------");
        InputStream inputStream = request.getInputStream();
        int len = -1;
        byte buf[] = new byte[512];//缓冲区
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        while ((len = inputStream.read(buf)) != -1) {
            baos.write(buf, 0, len);
        }
        String requestJson = new String(baos.toByteArray(), "UTF-8");
        ObjectMapper objectMapper = new ObjectMapper();
        Map<Object, Object> requestMap = objectMapper.readValue(requestJson, Map.class);
        System.out.println("requestMap=" + requestMap);
        System.out.println("-------------------------------------------------");
        Map<String, Object> dataMap = new HashMap<>();
        dataMap.put("code", "ok");
        ObjectMapper mapper = new ObjectMapper();
        String json = mapper.writeValueAsString(dataMap);
        response.setContentType("text/json;charset=UTF-8");
        response.setCharacterEncoding("UTF-8");
        PrintWriter writer = response.getWriter();
        writer.print(json);
        writer.flush();
    }

}

HttpClient4实现客户端调用

pom.xml

<dependencies>
    <!-- Web Dependencies -->
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>javax.servlet-api</artifactId>
        <version>3.1.0</version>
        <scope>provided</scope>
    </dependency>
    <!-- commons.lang3 -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.7</version>
    </dependency>
    <!-- 雪花算法 -->
    <dependency>
        <groupId>com.relops</groupId>
        <artifactId>snowflake</artifactId>
        <version>1.1</version>
    </dependency>
    <!-- jackson -->
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-core</artifactId>
        <version>2.13.1</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>2.13.1</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-annotations</artifactId>
        <version>2.13.1</version>
    </dependency>
    <!-- HttpClient-->
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.13</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpmime</artifactId>
        <version>4.5.13</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpasyncclient</artifactId>
        <version>4.1</version>
    </dependency>
    <!--测试使用 -->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.11</version>
        <scope>test</scope>
    </dependency>
    <!-- lombok插件-->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.20</version>
        <scope>provided</scope>
    </dependency>
</dependencies>

实现的工具类

package com.what21.httpclient4;

import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicHeader;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

import java.io.IOException;
import java.util.*;

public class HttpClientHelperUtils {

    /**
     * @param url
     * @return
     */
    public static String get(String url) {
        String result = null;
        HttpEntity httpEntity = null;
        try {
            CloseableHttpClient httpClient = HttpClients.createDefault();
            // 创建POST
            HttpGet httpGet = new HttpGet(url);
            httpGet.setConfig(getRequestConfig());
            // 设置头参数
            Header header = new BasicHeader("Accept-Encoding", null);
            httpGet.setHeader(header);
            CloseableHttpResponse httpResponse = httpClient.execute(httpGet);
            httpEntity = httpResponse.getEntity();
            result = EntityUtils.toString(httpEntity);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                EntityUtils.consume(httpEntity);
            } catch (IOException e) {
                // http请求释放资源异常
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * @param url
     * @param paramsMap
     * @return
     */
    public static String post(String url, Map<String, String> paramsMap) {
        String result = null;
        HttpEntity httpEntity = null;
        try {
            CloseableHttpClient httpClient = HttpClients.createDefault();
            // 创建POST
            HttpPost httpPost = new HttpPost(url);
            httpPost.setConfig(getRequestConfig());
            // 设置头参数
            Header header = new BasicHeader("Accept-Encoding", null);
            httpPost.setHeader(header);
            // 添加参数
            List<NameValuePair> nameValuePairs = new ArrayList<>();
            if (paramsMap != null && paramsMap.size() > 0) {
                Set<String> keySet = paramsMap.keySet();
                Iterator it = keySet.iterator();
                while (it.hasNext()) {
                    String key = (String) it.next();
                    String value = paramsMap.get(key);
                    nameValuePairs.add(new BasicNameValuePair(key, value));
                }
            }
            httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs));
            // 执行
            CloseableHttpResponse httpResponse = httpClient.execute(httpPost);
            httpEntity = httpResponse.getEntity();
            result = EntityUtils.toString(httpEntity);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                EntityUtils.consume(httpEntity);
            } catch (IOException e) {
                // http请求释放资源异常
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * @param url
     * @param json
     * @return
     */
    public static String postByContentTypeToJson(String url, String json) {
        String result = null;
        HttpEntity httpEntity = null;
        try {
            CloseableHttpClient httpClient = HttpClients.createDefault();
            // 创建POST
            HttpPost httpPost = new HttpPost(url);
            httpPost.setConfig(getRequestConfig());
            // 设置头参数
            Header header = new BasicHeader("Accept-Encoding", null);
            httpPost.setHeader(header);
            // 头设置报文和通讯格式
            StringEntity stringEntity = new StringEntity(json, ContentType.APPLICATION_JSON);
            stringEntity.setContentEncoding("UTF-8");
            httpPost.setEntity(stringEntity);
            CloseableHttpResponse httpResponse = httpClient.execute(httpPost);
            httpEntity = httpResponse.getEntity();
            result = EntityUtils.toString(httpEntity);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                EntityUtils.consume(httpEntity);
            } catch (IOException e) {
                // http请求释放资源异常
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * @return
     */
    public static RequestConfig getRequestConfig() {
        RequestConfig requestConfig = RequestConfig.custom()
                .setSocketTimeout(180 * 1000) // 连接超时时间
                .setConnectTimeout(180 * 1000) // 请求超时时间
                .setConnectionRequestTimeout(180 * 1000) // 连接请求超时时间
                .setRedirectsEnabled(true) // 重定向开关
                .build();
        return requestConfig;
    }

}

工具类的调用案例

package com.what21.httpclient4;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;

import java.util.HashMap;
import java.util.Map;

public class HttpClientHelperUtilsDemo {

    public static void main(String[] args) {
        // get调用
        String getUrl = "http://localhost:9090/web/service/general?id=xfd&name=小奋斗";
        String getResult = HttpClientHelperUtils.get(getUrl);
        System.out.println(getResult);
        //===================================================================//
        // post context-type
        String postUrl = "http://localhost:9090/web/service/general";
        Map<String, String> paramsMap = new HashMap<>();
        paramsMap.put("id", "xfd");
        paramsMap.put("name", "小奋斗");
        String postResult = HttpClientHelperUtils.post(postUrl, paramsMap);
        System.out.println(postResult);
        //===================================================================//
        String postUrl2 = "http://localhost:9090/web/service/json";
        String json = "{}";
        try {
            Map<String, String> jsonMap = new HashMap<>();
            jsonMap.put("id", "xfd");
            jsonMap.put("name", "小奋斗");
            ObjectMapper mapper = new ObjectMapper();
            json = mapper.writeValueAsString(jsonMap);
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
        String postResultToJson = HttpClientHelperUtils.postByContentTypeToJson(postUrl2, json);
        System.out.println(postResultToJson);
    }

}

相关推荐

现代JavaScript的高级概念和用法(javascript高级语言程序设计)
现代JavaScript的高级概念和用法(javascript高级语言程序设计)

JavaScript语言不断发布一些新特性,感觉要上天的节奏啊。本文搜集整理了一些它的高级概念和用法,来看看你是否都了解?代码这样写是不是更优雅了?闭包闭包是J...

2023-03-21 19:16 xiyangw

用 JavaScript 让时间更人性化(javascript有什么用)

以下是一个JavaScript代码段,它可以将传入的字符串类型日期转换为“刚刚”、“几秒前”、“几分钟前”、“几个小时前”、“昨天”、“前天”或“几天前”等形式:“想象一下,你正在设计一个社交网站...

10 项必须知道的技术提升你的 JavaScript 技能
10 项必须知道的技术提升你的 JavaScript 技能

JavaScript是一种非常强大的编程语言,它通过提供构建动态和交互式网站的方法在Web开发中找到了自己的位置。它在开发人员和Web设计人员中的流行...

2023-03-21 19:15 xiyangw

浅谈JavaScript的用处(javascript以及javascript的作用)
浅谈JavaScript的用处(javascript以及javascript的作用)

我把JS理解为,页bai面的du化妆zhi术。我们dao就是化妆者,通过JS,我们可以把一zhuan个页面全我们想要的shu意思进行渲染,执行相应的功能,生成相...

2023-03-21 19:15 xiyangw

报告显示:JavaScript成为最受欢迎的技术(9 条非常强大的javascript 技巧)
报告显示:JavaScript成为最受欢迎的技术(9 条非常强大的javascript 技巧)

JavaScript成为最受开发人员欢迎的技术。PluralsightTechnologies发布了其技术索引,并发现JavaScript排名第一。去年公司在...

2023-03-21 19:14 xiyangw

JavaScript:5个 JS 解构有趣的用途(解构诡异)

为了保证的可读性,本文采用意译而非直译。1.交换变量通常交换两个变量的方法需要一个额外的临时变量,来看看例子:leta=1;letb=2;lettemp;temp=a;a...

为什么这么多人学习JavaScript?总结是3个原因
为什么这么多人学习JavaScript?总结是3个原因

JavaScript(JS)是一种面向对象的脚本语言,可用于各种不同的项目和创作,从网站开发到机器人编程。尽管JavaScript可能不像某些编程语言(如Pyt...

2023-03-21 19:14 xiyangw

JavaScript的基本精华概念(javascript的含义和作用)

JavaScript的基本精华概念对象JavaScript的简单类型包括数字、字符串、布尔值、null和undefined值。总共5种基本类型其他的所有值都是对象,数字、字符串和布尔值「貌...

10个超实用的JavaScript技巧,让你的日常工作更轻松
10个超实用的JavaScript技巧,让你的日常工作更轻松

在前面,我们也分享了很多关于JavaScript的技巧,今天我们再来看看这10个超级实用的技巧,希望能够对你有所帮助。1.过滤错误值如果要过滤数组中的false...

2023-03-21 19:14 xiyangw

惊人揭秘:JavaScript的神秘起源(javascript的由来)

JavaScript是当今互联网上最广泛使用的编程语言之一,被用于网页交互、游戏开发、移动应用程序等众多领域。但是,你是否知道JavaScript的神秘起源?今天,我们将揭秘这个曾经让人疑惑的问题。1...

Web前端:什么是JavaScript框架?有什么作用?(web前端的三大框架)
Web前端:什么是JavaScript框架?有什么作用?(web前端的三大框架)

  有许多最好的JavaScript框架可供Web开发人员使用,它们各有利弊。JavaScript框架为JavaScript开发人员提供了开发J...

2023-03-21 19:13 xiyangw

Web前端:JavaScript编程语言有哪些优势?(javascript库有哪些)
Web前端:JavaScript编程语言有哪些优势?(javascript库有哪些)

  JavaScript编程语言是web开发中最简单、最全面、最面向结果的语言之一。这种语言使得数据的处理和计算变得轻而易举。这也有助于增加屏幕的视觉效果。  ...

2023-03-21 19:13 xiyangw

为什么JavaScript这么火?都有哪些作用?(javascript用来干嘛)
为什么JavaScript这么火?都有哪些作用?(javascript用来干嘛)

JS的热度一直不减,很多程序员对它的评价就是“能担当大任”,评价之高可见对JS的青睐程度不同一般。无论事物还是人物,不可能想想就能火起来的,都是有一定原因的。J...

2023-03-21 19:13 xiyangw

关于JavaScript你可能不知道的7个功能(您保存的文件格式可能包含有不兼容的功能,如何解决)
关于JavaScript你可能不知道的7个功能(您保存的文件格式可能包含有不兼容的功能,如何解决)

技术领域总是充满着神秘的未知和挑战,有趣又令人不能自拔。就像JavaScript,即使是每天使用它进行开发交互的开发人员,而语言的某些部分仍然未被开发。本篇文...

2023-03-21 19:12 xiyangw

快来领取,33个常用JavaScript功能已封装成方法,拿来即用
快来领取,33个常用JavaScript功能已封装成方法,拿来即用

在实际开发中,为了提高开发的效率,我们会把常用到的功能封装成方法,这样后期开发需要,拿来即用。这里分享33个在实际开发中经常需要用到的功能(已封装成方法),分享...

2023-03-21 19:12 xiyangw

取消回复欢迎 发表评论: