使用套接字从服务器线程中的套接字读取数据

Question

应用程序具有客户端和服务器线程。客户端线程正常工作。 在从服务器读取其他应用程序的客户端发送给我的应用程序的过程中出现问题。

有两个要求来实现这个服务器

1. 我需要使用UTF-16LE编码
2. 我不能使用输入行，我只需要使用读取字节/秒

我尝试了很多例子，但似乎没有任何工作正常。

这里是服务器

private static final int NUM_STATUSES = 30; 
private static final int NUM_ERRORES  = 50; 
private ServerSocket  _serverSocket; 
private Socket    _socket; 
private Handler    _handler; 
private int     _port; 

//handler of main activity 
public ServerNetworkThread() 
{ 
    setName("ServerNetworkThread"); 
} 

public void setHandler(Handler h) 
{ 
    _handler = h; 
} 

@Override 
public void run() 
{ 

    _isWorking = true; 
    try 
    { 
     _serverSocket = new ServerSocket(); 
     _serverSocket.setReuseAddress(true); 
     _serverSocket.bind(new InetSocketAddress(_port)); 

     while (_isWorking) 
     { 
      _socket = _serverSocket.accept(); 
      _socket.setSoTimeout(Consts.CLIENT_SOCKET_TIMEOUT); 

      readDataTest(); 

     } 

    } 
    catch (SocketTimeoutException e) 
    { 
     e.printStackTrace(); 
    } 
    catch (IOException e) 
    { 
     e.printStackTrace(); 
    } 

} 

private void readDataTest() throws IOException 
{ 
    //   BufferedReader inFromClient = new BufferedReader(new InputStreamReader(_socket.getInputStream(),Charset.forName("UTF-16LE"))); 
    InputStream iStream = _socket.getInputStream(); 
    InputStreamReader in = new InputStreamReader(iStream, Charset.forName("UTF-16LE")); 
    DataOutputStream outToClient = new DataOutputStream(_socket.getOutputStream()); 
    char[] buf = new char[iStream.available()]; 
    in.read(buf, 0, buf.length); 
    String request = new String(buf); 

    String responseStr = parseResponse(request); 
    byte[] response = responseStr.getBytes("UTF-16LE"); 
    outToClient.write(response); 
    outToClient.flush(); 
    outToClient.close(); 
    in.close(); 
    _socket.close(); 
    //   inFromClient.close(); 
} 

的有时候我收到的时候我试图读取服务器从客户端接收数据超时的代码。

感谢您的帮助

Answer 1

的问题，你的答案是不是有些神秘的EOF字符，它是你忽略了读取计数的代码。它应该是

int count = in.read(buf); 
if (count == -1) 
    throw new EOFException(); 
String request = new String(buf, 0, count);` 

Answer 2

我曾经处理过类似的问题。我需要使用UTF-16编码为UTF-8的字节来获取字符串。所以我写了这个方法，这样做：

//NOTE: 'charsetName' has to be a valid Name (see 'Charset'-Class in the API) 
public String encode(char[] data, String charsetName) 
{ 
    //Convert char[] to a String 
    String charString = String.copyValueOf(data); 
    String encoded = ""; 

    try 
    { 
     //Since there is no constructor which lets you set char[] with encoding 
     //convert your String to a byte-Array. There is a constructor which lets 
     //you set the Encoding for it. 
     byte[] bytesEncoded = charString.getBytes(charsetName); 

     //Construct a String using the encoding 
     encoded = new String(bytesEncoded, charsetName); 
    } 
    catch (UnsupportedEncodingException e) 
    { 
     e.printStackTrace(); 
    } 

    return encoded; 
} 

（您可以设定“UTF-16LE”是的charsetName）

看起来有点“脏”数据转换来回，但对我来说非常完美。

Answer 3

到底对我有什么工作是：

1. 我总是在分配大小为1024的缓冲区，而无需使用iStream.available（）作为阿塔注意到。
2. 经过多次尝试，我没有想到如何在“EOF”后逃脱所有的字符。我只是通过EOF分割接收到的字符串并获取字符串的第一个片段，它工作得很好。 EOF符号结束来自客户端的请求。

这是我最后使用

private void readDataTest() throws IOException 
{ 
    InputStream iStream = _socket.getInputStream(); 
    InputStreamReader in = new InputStreamReader(iStream, Charset.forName("UTF-16LE")); 
    DataOutputStream outToClient = new DataOutputStream(_socket.getOutputStream()); 
    char[] buf = new char[1024]; 
    in.read(buf, 0, buf.length); 
    String request = new String(buf); 
    request = request.split(Consts.EOF)[0]; 

    String responseStr = parseResponse(request); 
    byte[] response = responseStr.getBytes("UTF-16LE"); 
    outToClient.write(response); 
    outToClient.flush(); 
    outToClient.close(); 
    in.close(); 
    _socket.close(); 
}