Java Socket中time_wait有关问题-Java教程-爱易网页

Java Socket中time_wait有关问题

日期：2014-05-20　浏览次数：20885 次

Java Socket中time_wait问题。
在进行压力测试的时候，我们的系统A 高并发的请求另外一个系统B，是tcp通讯方式。A系统采用Java，B系统用的C语言。在高并发的情况下，跑了一段压力测试，weblogic10被系统给kill掉了。没有堆栈异常现象，后来重现了发现有大量的端口time_wait。根据这样的判断应该是welogic在不断的申请系统资源，而这些端口有没有得到及时的释放。后来在通讯层的代码解决了。

现在对这部分还不是很了解。于是自己写了简单的例子看看这个问题。

Java code


          //读取流中字节的方法
          private byte[] readMessage(InputStream is) throws IOException{
        int bufferSize = 0;
        int bufferCapacity = maxbytes;
        byte[] b = new byte[bufferCapacity];
        int numberRead = 0;
        do{
            if((numberRead = is.read(b,bufferSize,bufferCapacity - bufferSize)) == -1){
                break;
            }
            bufferSize += numberRead;
            if(bufferSize == bufferCapacity){
                bufferCapacity = 2 * bufferCapacity;
                byte[] newBuffer = new byte[bufferCapacity];
                System.arraycopy(b,0,newBuffer,0,bufferSize);
                b = newBuffer;
            }
        }while(true);    
        //过滤后面的多余字节
        while(b[bufferSize - 1] == 0x00){
            bufferSize--;
        }
        byte[] res = new byte[bufferSize];
        System.arraycopy(b,0,res,0,res.length);
        return res;
    }
         //写数据的方法
         private void writeMessage(OutputStream os,byte[] buff) throws IOException{
        os.write(buff);
        os.flush();
    }

服务端的程序：服务端只是接收数据。不发送。

Java code


package com.haowei.socket.tcp;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import com.haowei.JavaSocketUtil;

public class Server {
    public static void main(String[] args) throws IOException {
        int count = 0;
        ServerSocket server = new ServerSocket(9999);
        System.out.println("......服务开启监听.....");
        while(true){
            Socket socket = server.accept();
            new Thread(new ServerThread(String.valueOf(count),socket)).start();
            count ++;
        }
    }
}

class ServerThread implements Runnable{
    private Socket socket;
    private String name;
    
    public ServerThread(String name,Socket socket) {
        super();
        this.name = name;
        this.socket = socket;
    }
    
    @Override
    public void run() {
        System.out.println("线程 [" + name + "]开始执行....");
        OutputStream os = null;
        InputStream is = null;
        byte[] data = null;
        try {
            os = socket.getOutputStream();
            is = socket.getInputStream();
            data = JavaSocketUtil.readMessage(socket);
            System.out.println("线程 [" + name + "]收到的数据:-->" + new String(data));
//            String resp = "我是服务端返回的数据。";
//            JavaSocketUtil.writeMessage(socket,resp.getBytes());
        } catch (IOException e1) {
            e1.printStackTrace();
        }
        try {
            if(socket!=null){
                System.out.println("线程[" + name + "]关闭连接。");
                socket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }
    
}

客户端代码：客户端只是发送数据

Java code


package com.haowei.socket.tcp;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

import com.haowei.JavaSocketUtil;

public class Client {
    public static void main(String[] args) throws UnknownHostException, IOException{
        int count = 0;
        while(count<1000){
            Socket socket = new Socket("127.0.0.1",9999);
            new Thread(new ClientThread(String.valueOf(count),socket)).start();
            count ++;
        }
    }
}

class ClientThread implements Runnable{
    private Socket socket;
    private String name;
    
    public ClientThread(String name,Socket socket) {
        super();
        this.socket = socket;
        this.name = name;
    }

    public void run(){
        System.out.println("客户端线程 [" + name + "]开始执行....");
        OutputStream os = null;
        InputStream is = null;
        byte[] data = null;
        try {
            os = socket.getOutputStream();
            is = socket.getInputStream();
            String resp = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
            JavaSocketUtil.writeMessage(socket,resp.getBytes());
//            data = JavaSocketUtil.readMessage(socket);
//            System.out.println("读取的数据:-->" + new String(data));
        } catch (Exception e1) {
            e1.printStackTrace();
        }
//        try {
//            socket.close();
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
    }
}

免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。

Java Socket中time_wait有关问题

相关资料更多>

推荐阅读更多>