天天看点

解决上银联长短连接问题

前段时间,公司新接上银联支付通道,在测试的时候,没有出现超时的问题,但是到生产总是出现验证码发送失败的情况,翻看日志发现是请求上银联出现超时(connection reset的情况)。然后商量确定请求方式,他们确定说他们是短连接,我这边通过fiddler抓包发现我们这边使用的是长连接,商量我们这边先调整为短连接试试。

  1. TCP长短连接概念
http(HyperText Transfer Protocol),超文本传输协议,是互联网上应用最广泛的一种网络协议,所有www文件都必须遵守的一个标准,是以 ASCII 码传输,建立在 TCP/IP 协议之上的应用层规范。长连接是指在请求服务端在建立连接后,下次请求后不需要重新建立连接其实就是三次握手,短连接就是每次请求完就断开连接,下次需要重新三次握手和四次分手。
解决上银联长短连接问题

流程:

第一次握手

建立连接。客户端发送连接请求报文段,将SYN位置为1,Sequence Number为x;然后,客户端进入SYN_SEND状态,等待服务器的确认;

第二次握手

服务器收到SYN报文段。服务器收到客户端的SYN报文段,需要对这个SYN报文段进行确认,设置Acknowledgment Number为x+1(Sequence Number+1);同时,自己自己还要发送SYN请求信息,将SYN位置为1,Sequence Number为y;服务器端将上述所有信息放到一个报文段(即SYN+ACK报文段)中,一并发送给客户端,此时服务器进入SYN_RECV状态;

第三次握手

客户端收到服务器的SYN+ACK报文段。然后将Acknowledgment Number设置为y+1,向服务器发送ACK报文段,这个报文段发送完毕以后,客户端和服务器端都进入ESTABLISHED状态,完成TCP三次握手

为什么要三次握手

为了防止已失效的连接请求报文段突然又传送到了服务端,因而产生错误。

解决上银联长短连接问题

流程:

第一次分手

主机1(可以使客户端,也可以是服务器端),设置Sequence Number,向主机2发送一个FIN报文段;此时,主机1进入FIN_WAIT_1状态;这表示主机1没有数据要发送给主机2了;

第二次分手

主机2收到了主机1发送的FIN报文段,向主机1回一个ACK报文段,Acknowledgment Number为Sequence Number加1;主机1进入FIN_WAIT_2状态;主机2告诉主机1,我“同意”你的关闭请求;

第三次分手

主机2向主机1发送FIN报文段,请求关闭连接,同时主机2进入LAST_ACK状态;

第四次分手

主机1收到主机2发送的FIN报文段,向主机2发送ACK报文段,然后主机1进入TIME_WAIT状态;主机2收到主机1的ACK报文段以后,就关闭连接;此时,主机1等待2MSL后依然没有收到回复,则证明Server端已正常关闭,那好,主机1也可以关闭连接了。

为什么要四次分手

TCP协议是一种面向连接的、可靠的、基于字节流的运输层通信协议。TCP是全双工模式,这就意味着,当主机1发出FIN报文段时,只是表示主机1已经没有数据要发送了,主机1告诉主机2,它的数据已经全部发送完毕了;但是,这个时候主机1还是可以接受来自主机2的数据;当主机2返回ACK报文段时,表示它已经知道主机1没有数据发送了,但是主机2还是可以发送数据到主机1的;当主机2也发送了FIN报文段时,这个时候就表示主机2也没有数据要发送了,就会告诉主机1,我也没有数据要发送了,之后彼此就会愉快的中断这次TCP连接。

HTTP协议常见的有HTTP1.0和HTTP1.1,以前以为HTTP连接分为长连接和短连接,而我们现在常用的都是HTTP1.0默认使用短连接,HTTP1.1默认使用的是长连接,其实这句话是错误的,HTTP没有长短连接这一回事,HTTP协议是基于请求/响应模式的,因此只要服务端给了响应,本次HTTP连接就结束了,或者更准确的说,是本次HTTP请求就结束了,根本没有长连接这一说。那么自然也就没有短连接这一说了。TCP连接是一个双向的通道,它是可以保持一段时间不关闭的,因此TCP连接才有真正的长连接和短连接这一说。
  1. 怎么修改长短连接

使用fiddler抓http包,得在代码中加入一行代码,一开始没有加入,发现http请求怎么也没看到,各种翻阅资料才发现自己少了代理:httpClient.getHostConfiguration().setProxy(“127.0.0.1”, 8888); 加上这句话你就能捕获你的http请求了。

在HTTP1.1协议抓包的过程中你会发现是 Connection: keep-alive是这个值,keep-alive就是长连接,属性Close是短连接,当然服务器和客户端都设置才可以。

  1. httpclient实现短链接
思路:设置HTTP协议版本;设置请求头为 Connection: close;其次在请求完释放连接。
public static final String CHARSET_UTF_8 = "UTF-8";
     public static final String CHARSET_GBK = "GBK";
     public static final String CONTENT_TYPE_TEXT_HTML = "text/tHtml";
     public static final String CONTENT_TYPE_APPLICATION_FORM = ·"application/x-www-form-urlencoded";
     private static HttpClient httpClient = null;
     private static final String HTTP_METHOD_GET = "GET";
     private static final String CONTENT_TYPE = "text/tHtml;charset=UTF-8";

public static String postData(String cUrlStr,
              Map<String, String> cParamMap, String cCharsetType)
              throws Exception {
              
          HttpClientParams httpClientParams = new HttpClientParams();
          //设置协议版本为1.0
          httpClientParams.setVersion(HttpVersion.HTTP_1_0);   
          if (httpClient == null) {
               httpClient = new HttpClient(httpClientParams);
          }     
          // 设置代理,实现fiddler抓包
          httpClient.getHostConfiguration().setProxy("127.0.0.1", 8888);
          
          httpClient.getHttpConnectionManager().getParams()
                   .setConnectionTimeout(60000);
          httpClient.getHttpConnectionManager().getParams().setSoTimeout(60000);
          logger.info("HTTP 发送请求开始");
          PostMethodUtil tProcPost = new PostMethodUtil(cUrlStr);
          tProcPost.setRequestHeader("Connection", "close");
          Set tKeySet = cParamMap.keySet();
          for (Iterator i$ = tKeySet.iterator(); i$.hasNext();) {
              Object tKey = i$.next();
              String tKeyValue = String.valueOf(tKey);
              String tValue = (String) cParamMap.get(tKeyValue);
              if (tValue == null) {
                   tValue = "";
              }
              tProcPost.addParameter(tKeyValue, tValue);
          }
          logger.info("HTTP 请求开始");
          int tStatusCode = httpClient.executeMethod(tProcPost);
          logger.info(new StringBuilder().append("HTTP 返回状态码:")
                   .append(tStatusCode).toString());
          InputStream tResInputStream = null;
          StringBuffer tHtml = new StringBuffer();
          try {
              tResInputStream = tProcPost.getResponseBodyAsStream();
              BufferedReader tReader = new BufferedReader(new InputStreamReader(
                        tResInputStream, cCharsetType));
              String tTempBf = null;
              while ((tTempBf = tReader.readLine()) != null) {
                   tHtml.append(tTempBf);
              }
          } catch (IOException e) {
              e.printStackTrace();
          } finally {
              if (tResInputStream != null) {
                   tResInputStream.close();
              }
              if (tProcPost != null) {
                //释放连接
                tProcPost.releaseConnection();
              }
          }
          logger.info("HTTP 请求结束");
          logger.info("http请求消息头=" + tProcPost.getRequestHeaders());
          return new String(tHtml.toString().getBytes(cCharsetType), cCharsetType);
     }
           

参考文章:https://blog.csdn.net/qq_33616529/article/details/78288883