JAVA sockets read()接收数据超时阻塞的解决方法

0 0

JAVA sockets read()接收数据超时阻塞的解决方法5

遇到一个问题，用JAVA和Delphi写的服务端进行sockets交互。
当服务端返回给我一条String型字符串时，我能正常接收到（即使网络有延迟时，过一会仍然能接收到）。但当服务端不定时返回给我多条String型字符串时，我却一条都接收不到，一直阻塞中。代码如下：
private String ReadSocketsText(Socket socket){
   try
    socket.setSoTimeout(sotimeout);
    InputStream input = socket.getInputStream();
    BufferedReader in = new BufferedReader(new InputStreamReader(input));
    char[] sn = new char[1000];
    //read()会在这里阻塞。
    in.read(sn);
    String sc = new String(sn);
    return sc;
   }catch(IOException se){
   se.printStackTrace();
    return null;
   }
}
我查了下资料，read()是阻塞制的，当接收不到数据时会一直等待。但服务端虽然有延迟发送，但当服务端已经把String数据返回时，read()仍然处于阻塞中，没有收到任何一条数据。这是何解？该怎么解决。。。这个问题困惑我已经几个月了，到现在了仍然是没有解决方法。。
网上查了很多资料，试用了很多很多的方法，仍然解决不了。有人说用NIO的netty框架，但苦于不会使用。。。我只是想解决这么个问题，难道就这么难么？？

Java 阻塞长连接套接字 sockets

2014年1月19日 21:00

s565288909
20
0 0 4

2个答案按时间排序按投票排序

0 0

想我当年还用socket写过聊天室，这应该是不定时的吧。
public class SocketManager {
    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) {
        SocketManager manager = new SocketManager();
       manager.doListen();
    }

    public void doListen() {
        ServerSocket server;
       try {
            server = new ServerSocket(9991);
            while (true) {
                Socket client = server.accept();
                new Thread(new SSocket(client)).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    //服务器进程
    class SSocket implements Runnable {

        Socket client;

        public SSocket(Socket client) {
            this.client = client;
        }

        public void run() {
           DataInputStream input;
            DataOutputStream output;
            try {
                input = new DataInputStream(client.getInputStream());
                output = new DataOutputStream(client.getOutputStream());
//
                String listMsg = input.readUTF();
                output.writeUTF("Recive: " + listMsg + "    \r\n Thx...");
               System.out.println("Recive:   " + listMsg);
                listMsg = input.readUTF();
                output.writeUTF("Recive Second: " + listMsg + "    \r\n Thx...");
                System.out.println("Recive Second:   " + listMsg);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketClient {
public static void main(String[] args) {
         Socket socket = null;
        try {
             socket = new Socket("127.0.0.1", 9991);
            //向服务器端第一次发送字符串
            OutputStream netOut = socket.getOutputStream();
            DataOutputStream doc = new DataOutputStream(netOut);
             DataInputStream in = new DataInputStream(socket.getInputStream());
            //向服务器端第二次发送字符串
            doc.writeUTF("list");
            String res = in.readUTF();
             System.out.println(res);
             doc.writeUTF("bye");
             res = in.readUTF();
            System.out.println(res);
             doc.close();
             in.close();
         } catch (UnknownHostException e) {
             e.printStackTrace();
         } catch (IOException e) {
            e.printStackTrace();
         } finally {
             if (socket != null) {
                try {
                     socket.close();
                 } catch (IOException e) {
                }
             }
        }
     }

}

你看这个，你任意启动client，server总能读到数据。