JAVA网络编程之模拟表单提交-阿里云开发者社区

开发者社区> 蒋固金> 正文

JAVA网络编程之模拟表单提交

简介:
+关注继续查看

这一篇博客是对上一篇《JAVA网络编程之获取网络资源》的扩充,这一篇将使用HttpURLConnection来模拟一个表单的提交。在B/S架构的系统中,请求时通过浏览器与服务端进行交互的,提交请求参数时使用form表单进行提交,但是有很多时候,我们需要在程序中直接调用HTTP接口,同时需要传递一些参数,那么这个时候我们就可以通过使用HttpURLConnection来模拟表单的提交过程。

首先,我们可以对请求进行封装

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

/**
 * 请求
 * 
 * @author jianggujin
 * 
 */
public class HttpRequest
{
   /** 请求地址 **/
   private String url = null;
   /** 请求方法 **/
   private RequestMethod method = RequestMethod.GET;
   /** 编码 **/
   private String charset = "UTF-8";
   /** 请求头信息 **/
   private Map<String, String> headers = new HashMap<String, String>();
   /** 请求参数 **/
   private Map<String, List<String>> params = new HashMap<String, List<String>>();

   /**
    * 默认构造方法
    */
   public HttpRequest()
   {
   }

   /**
    * 构造方法
    * 
    * @param url
    */
   public HttpRequest(String url)
   {
      this.url = url;
   }

   /**
    * 构造方法
    * 
    * @param url
    * @param method
    */
   public HttpRequest(String url, RequestMethod method)
   {
      this.url = url;
      this.method = method;
   }

   /**
    * 获得请求地址
    * 
    * @return
    */
   public String getUrl()
   {
      return url;
   }

   /**
    * 设置请求地址
    * 
    * @param url
    */
   public void setUrl(String url)
   {
      this.url = url;
   }

   /**
    * 获得请求方法
    * 
    * @return
    */
   public RequestMethod getMethod()
   {
      return method;
   }

   /**
    * 设置请求方法
    * 
    * @param method
    */
   public void setMethod(RequestMethod method)
   {
      this.method = method;
   }

   /**
    * 获得编码
    * 
    * @return
    */
   public String getCharset()
   {
      return charset;
   }

   /**
    * 设置编码
    * 
    * @param charset
    */
   public void setCharset(String charset)
   {
      this.charset = charset;
   }

   /**
    * 添加头信息
    * 
    * @param name
    * @param value
    */
   public void addHeader(String name, String value)
   {
      headers.put(name, value);
   }

   /**
    * 添加请求参数
    * 
    * @param name
    * @param value
    */
   public void addParam(String name, String value)
   {
      List<String> list = params.get(name);
      if (list == null)
      {
         list = new ArrayList<String>();
         params.put(name, list);
      }
      list.add(value);
   }

   /**
    * 设置请求参数
    * 
    * @param name
    * @param value
    */
   public void setParam(String name, String value)
   {
      List<String> list = params.get(name);
      if (list == null)
      {
         list = new ArrayList<String>();
         params.put(name, list);
      }
      else
      {
         // 清空已有参数
         list.clear();
      }
      list.add(value);
   }

   /**
    * 获得请求头迭代器
    * 
    * @return
    */
   public Iterator<Entry<String, String>> getHeaders()
   {
      return headers.entrySet().iterator();
   }

   /**
    * 获得请求参数迭代器
    * 
    * @return
    */
   public Iterator<Entry<String, List<String>>> getParams()
   {
      return params.entrySet().iterator();
   }

}

/**
 * 请求方法
 * 
 * @author jianggujin
 * 
 */
enum RequestMethod
{
   GET, POST
}

在HttpRequest类中,包含了一个请求的基本信息,然后我们再封装一个类用于HTTP的请求。

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.Iterator;
import java.util.List;
import java.util.Map.Entry;

/**
 * Http请求客户端
 * 
 * @author jianggujin
 * 
 */
public abstract class HttpClient
{
   /** 连接超时时间 **/
   private int connectTimeOut = 10 * 1000;
   /** 读超时时间 **/
   private int readTimeOut = 10 * 1000;

   /**
    * 获得连接超时时间
    * 
    * @return
    */
   public int getConnectTimeOut()
   {
      return connectTimeOut;
   }

   /**
    * 设置连接超时发时间
    * 
    * @param connectTimeOut
    */
   public void setConnectTimeOut(int connectTimeOut)
   {
      this.connectTimeOut = connectTimeOut;
   }

   /**
    * 获得读超时时间
    * 
    * @return
    */
   public int getReadTimeOut()
   {
      return readTimeOut;
   }

   /**
    * 设置读超时时间
    * 
    * @param readTimeOut
    */
   public void setReadTimeOut(int readTimeOut)
   {
      this.readTimeOut = readTimeOut;
   }

   /**
    * 执行
    */
   public void execute(HttpRequest request) throws IOException
   {
      String url = request.getUrl();
      // GET方式请求
      if (request.getMethod() == RequestMethod.GET)
      {
         // 拼接参数
         if (url.indexOf('?') != -1)
         {
            if (url.endsWith("?"))
            {
               url += dealParam(request);
            }
            else
            {
               if (url.endsWith("&"))
               {
                  url += dealParam(request);
               }
               else
               {
                  url += ("&" + dealParam(request));
               }
            }
         }
         else
         {
            url += ("?" + dealParam(request));
         }
      }
      // 获得Http连接
      HttpURLConnection connection = (HttpURLConnection) new URL(url)
            .openConnection();
      // 设置超时时间
      connection.setConnectTimeout(connectTimeOut);
      connection.setReadTimeout(readTimeOut);

      // 设置请求头
      Iterator<Entry<String, String>> headers = request.getHeaders();
      while (headers.hasNext())
      {
         Entry<String, String> entry = headers.next();
         connection.setRequestProperty(entry.getKey(), entry.getValue());
      }

      connection.setUseCaches(false);

      // 如果是POST请求
      if (request.getMethod() == RequestMethod.POST)
      {
         connection.setDoInput(true);
         connection.setDoOutput(true);
         connection.setRequestMethod("POST");
      }

      connection.connect();

      // 如果是POST请求
      if (request.getMethod() == RequestMethod.POST)
      {
         OutputStreamWriter writer = new OutputStreamWriter(
               connection.getOutputStream(), request.getCharset());
         writer.write(dealParam(request));
         writer.flush();
         writer.close();
      }

      if (connection.getResponseCode() == HttpURLConnection.HTTP_OK)
      {
         onSuccess(HttpURLConnection.HTTP_OK, connection.getInputStream());
      }
      else
      {
         onSuccess(connection.getResponseCode(), connection.getErrorStream());
      }
      connection.disconnect();
   }

   /**
    * 处理请求参数
    * 
    * @param request
    * @return
    * @throws IOException
    */
   private String dealParam(HttpRequest request) throws IOException
   {
      StringBuilder builder = new StringBuilder();
      Iterator<Entry<String, List<String>>> iterator = request.getParams();
      int count = 0;
      // 遍历请求参数
      while (iterator.hasNext())
      {
         Entry<String, List<String>> entry = iterator.next();
         List<String> list = entry.getValue();
         for (String string : list)
         {
            if (count > 0)
            {
               builder.append("&");
            }
            builder.append(entry.getKey()).append("=");
            if (request.getMethod() == RequestMethod.GET)
            {
               builder.append(URLEncoder.encode(string, request.getCharset()));
            }
            else
            {
               builder.append(string);
            }
            count++;
         }
      }
      return builder.toString();
   }

   /**
    * 出错时执行
    * 
    * @param code
    * @param stream
    * @throws IOException
    */
   public abstract void onError(int code, InputStream stream)
         throws IOException;

   /**
    * 成功时执行
    * 
    * @param code
    * @param stream
    * @throws IOException
    */
   public abstract void onSuccess(int code, InputStream stream)
         throws IOException;
}

为了方便测试,简单的编写一个Servlet,代码如下:

package com.jhq.wx.servlet;

import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

public class Test extends HttpServlet
{
   protected void doGet(HttpServletRequest request, HttpServletResponse response)
         throws ServletException, IOException
   {
      System.out.println(request.getParameter("p1"));
      System.out.println(request.getParameter("p2"));
   }

   protected void doPost(HttpServletRequest request,
         HttpServletResponse response) throws ServletException, IOException
   {
      request.setCharacterEncoding("UTF-8");
      System.out.println(request.getParameter("p1"));
      System.out.println(request.getParameter("p2"));
   }
}

最后编写一个测试类,测试模拟表单提交

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

public class Test
{
   public static void main(String[] args)
   {
      HttpRequest request = new HttpRequest("http://127.0.0.1/wx/s");
      request.addParam("p1", "123");
      request.addParam("p2", "蒋固金");
      request.setMethod(RequestMethod.POST);
      HttpClient client = new HttpClient()
      {

         @Override
         public void onSuccess(int code, InputStream stream) throws IOException
         {
            // 内容是文本,直接以缓冲字符流读取
            BufferedReader reader = new BufferedReader(new InputStreamReader(
                  stream, "UTF-8"));
            String data = null;
            while ((data = reader.readLine()) != null)
            {
               System.out.print(data);
            }
            reader.close();
         }

         @Override
         public void onError(int code, InputStream stream)
         {
            System.out.println("请求出现异常");
         }
      };
      try
      {
         client.execute(request);
      }
      catch (IOException e)
      {
         e.printStackTrace();
      }
   }
}

运行之后,我们可以看到服务端后台输出:
123
蒋固金

这样就完成了Java模拟表单提交的操作。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
磨刀不误砍柴工,搞定云网络系统性能测试
在本文中,首先简单介绍一下网络性能测试指标重点会关注哪些指标、在开展性能测试时,如何预估系统性能以便合理的规划和部署测试环境,然后会介绍基本的网络连通性测试工具、网络性能测试工具以及在开展性能测试时如何部署监控,更加直观的统计性能指标等。
226 0
Java网络编程(TCP_UDP)
版权声明:本文为博主原创文章,转载请注明出处。 https://blog.
787 0
IOCP模型与网络编程
一。前言:        在老师分配任务(“尝试利用IOCP模型写出服务端和客户端的代码”)给我时,脑子一片空白,并不知道什么是IOCP模型,会不会是像软件设计模式里面的工厂模式,装饰模式之类的那些呢?嘿嘿,不过好像是一个挺好玩的东西,挺好奇是什么东西来的,又是一个新知识啦~于是,开始去寻找一大堆的资料,为这个了解做准备,只是呢,有时还是想去找一本书去系统地学习一下,毕竟网络的资料还是有点零散。
895 0
Java网络编程--套接字Socket
一、套接字Socket IP地址标志Internet上的计算机,端口号标志正在计算机上运行的进程(程序)。 端口号被规定为一个16位的0--65535之间的整数,其中,0--1023被预先定义的服务通信占用。
544 0
06.Java网络编程(java GUI实现的聊天界面)
目前测试存在两个问题 1.最初是继承Frame来实现界面显示,后来发现,界面中部分控件存在时而显示时而不显示的问题,查找资料之后,将Frame修为JFrame,并且修改setVisible的时机,界面显示的问题解决,不显示的原因,有一种说法就是注释中提到的 2.
1145 0
05.Java网络编程(代码实践)
计算机网络是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过通信线路链接起来,在网络操作系统,网络管理软件及网络通信协议的协调下,实现资源贡献和信息传递的计算机系统 网络编程就是用来实现网络互连的不同计算机上运行的程序间可以进行数据交换 网...
786 0
04.Java网络编程(转载)
1.网络编程   1.1计算机网络概述   网络编程的实质就是两个(或多个)设备(例如计算机)之间的数据传输。   按照计算机网络的定义,通过一定的物理设备将处于不同位置的计算机连接起来组成的网络,这个网络中包含的设备有:计算机、路由器、交换机等等。
803 0
+关注
115
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载