博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
话说Connect reset异常
阅读量:4214 次
发布时间:2019-05-26

本文共 3019 字,大约阅读时间需要 10 分钟。

     起因是这样的,线上log经常出现Connection Reset异常,从堆栈上分析是solr进行sharding request时发生的,solr部署在tomcat上。从现场来看,原因很明白Server端发出RST包。但具体原因是什么就得经过一番分析了,

    经过google百度以及和网友沟通,发现会有以下场景导致RST:
    1. 设置SoLinger,并设置停留时间为0
     显然不是这样的场景,如是则会经常出现,而不是偶尔出现。还有其他的吗?我翻看了一下TCP/IP详解,TCP的连接与终止以及复位报文段。有点收获但还是没有看太懂,呵呵答案就在书上,也许没有沉下心去,一开始并没有书上介绍套出问题的场景。后来看到oracle的一篇文章 .
发现异常关闭非常适合出现问题的场景。啥叫异常关闭呢,正常的close是四次挥手
例如客户端执行close的时候,发出FIN,告诉对端我不再接受和发送数据,而对端也应该由应用程序调用close结束链接,也许你会说发出FIN只是告诉对端不再发送数据还能接收数据,事实上也是可以的,这样的关闭叫做半关闭,通过调用shutdown方法来实现。
   solr为什么会遇到这样的问题,httpclient为了减少链接的建立开销使用connection manager的连接池管理链接,我们知道虽然Http1.1支持keep alive,但仍有条件限制,例如keepalivetimeout以及keepalive的个数。当tomcat进行keepalive的connectin timeout处理的处理的,只是单方面的close,对端趟在连接池中的connection并不知道也不会执行相应的close,恰巧这时候有一个reuest使用这个connection发出请求,这一点特别重要,还是能发送数据的,最初的时候我以为服务端close了客户端就不能再使用conneciton发送数据了。服务端不会读取client端发过来的数据坚决执行关闭,这时候这个关闭就是RST而不是FIN了。
B's TCP stack knows that some data is effectively lost and it will forcibly terminate with RST rather than use the orderly 
FIN
 procedure.
   有两种这样的场景:
   1. A向B 发送数据,B的应用执行close,而这时A试图继续发而不是由应用调用close。
   2. A向B发送数据,B不做任何处理,不读取任何数据坚决地close,这时候这个close发的就是RST。
   我写了一段代码来模拟以上两种情况
Server
public static void run(){                try{                        //InetSocketAddress address = new InetSocketAddress("10.58.99.27", 9090);                    //InetAddress address =     InetAddress.getByName("10.58.99.27");            ServerSocket serverSocket = new ServerSocket(9090,1);            ExecutorService threadPool = Executors.newCachedThreadPool();//            for(int i = 0; i < 1;i++){//              new Thread(new BioHttpServer.Connector()).start();//            }//            latch.countDown();            while(true){                   Socket client = serverSocket.accept();                   Thread.sleep(1000);//调整这个时间 如调整为100 则为情况1 1000为情况2                   client.close();                 //  client.shutdownOutput();//                   if(isDistribute){//                         threadPool.execute(new SocketProcessor(client));//                   }else{//                         new SocketProcessor(client).run();//                   }                }               }catch(Exception e){             e.printStackTrace();        }finally{            }           }
 Client
try {                        Socket client = new Socket("10.58.99.74", 9090);                        //      client.setSoTimeout(5000);                                System.out.println(client);                                InputStream ins =client.getInputStream();                                int i = 0;                //              System.out.println(ins.read());                                while(i++ < 100000){                                   client.getOutputStream().write(64);                                }                                   System.out.println(ins.read());                } catch (UnknownHostException e) {                        e.printStackTrace();                } catch (IOException e) {                        e.printStackTrace();                }
 

转载地址:http://kqdmi.baihongyu.com/

你可能感兴趣的文章
c/c++实现字符串分隔split
查看>>
蓝桥杯 2017_7 日期问题(c与c++知识学习)
查看>>
扩展欧几里得求逆元、中国剩余定理
查看>>
蓝桥杯 2017_9 包子问题
查看>>
蓝桥杯2017_10 k倍区间
查看>>
贪心 : 51nod 活动安排(活动选房间)
查看>>
人工智能实验 猴子摘香蕉
查看>>
贪心: 独木舟问题
查看>>
python 切片实现trim函数(去除首尾空格)
查看>>
python 用列表生成器 打印杨辉三角
查看>>
python 函数式编程 map、reduce用法
查看>>
python高级特性 sorted(自定义排序)
查看>>
贪心 :多任务执行
查看>>
python 实现系统文件、目录操作
查看>>
python 序列化(JSON)
查看>>
python 多进程
查看>>
python 多线程
查看>>
贪心:huffman编码
查看>>
贪心:dijkstra
查看>>
python 文件读取 read、readline、readlines
查看>>