java - J2ME - 无法关闭客户端的输出流，服务器挂起等待数据 [nokia J2ME 实现]

Question

我的问题是:有没有一种方法可以执行套接字 OutputStream 关​​闭，或者它没有正确/完全实现，诺基亚应该这样做？ (J2ME nokia 实现，在 nokia c6-00 上测试并且没有关闭流，在模拟器上测试并且工作正常)

主要问题是 J2SE 服务器应用程序没有获取流信息的结尾，条件 read(buffer) == -1 永远不会为真，尝试从空流中读取并挂起，直到客户端被强制终止。这适用于服务器端应用程序上非常、非常、非常丑陋的解决方法

        Thread.sleep(10);//wait some time for data else you would get stuck........
        while ((count = dataInputStream.read(buffer)) != -1) {
            byteArrayOutputStream.write(buffer, 0, count);
            if (count != BUFFER_SIZE_1024 || dataInputStream.available() == 0) { //the worlds worst condition ever written... but works
                break;
            }
            Thread.sleep(10);//wait for data input to get some data for dataInputStream.available() to return != 0 if client still sends data else you would not read all data......
        }

但是这个解决方案是绝对不能接受的(我对诺基亚 java 编码一无所知，我遗漏了一些东西，或者它可能类似于某种 nokia-J2ME 编码标准，我应该习惯它或改变它平台)

我无法在发送数据后关闭客户端套接字，因为服务器在接收和处理数据后向客户端发送响应。

它看起来像这样:J2ME 客户端 -> J2SE 服务器(因为客户端不执行输出流关闭而挂起读取) -> J2ME

我尝试过:关闭 J2ME 客户端上的 dataOutputStream - 无效setSocketOptions(KEEPALIVE、SNDBUF 和其他)- 无效或错误

在目标设备上似乎没有任何效果

抱歉，在与 little java 的这种无意义的战斗之后，我现在有点生气。

我已经搜索了解决方案，但似乎没有用

客户端代码:

        SocketConnection socketConnection = (SocketConnection) Connector.open("socket://" + ip + ":" + port);
        int count;
        byte[] buffer = new byte[BUFFER_SIZE_1024];
        // client -> server
        DataOutputStream dataOutputStream = new DataOutputStream(socketConnection.openDataOutputStream());
        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
        while ((count = byteArrayInputStream.read(buffer)) != -1) {
            dataOutputStream.write(buffer, 0, count);
            dataOutputStream.flush();
        }
        dataOutputStream.close();
        byteArrayInputStream.close();

Answer 1

对于 J2SE，我的建议是从 java.nio.channels.SocketChannel 初始化 Socket，并在合理的超时到期后中断阻塞的线程。

我不确定您要修复哪一侧，但看起来对于 J2ME，您唯一的选择是 set socket timeout .

编辑

实际上，既然您已经发布了客户端代码，我就明白了问题所在。无论出于何种原因从 while 循环中抛出异常，输出流都不会关闭。

这是我建议的修复方法:

    ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);

    try
    {
        DataOutputStream dataOutputStream = new DataOutputStream(
                  socketConnection.openDataOutputStream()
                  );
        try
        {
            while ((count = byteArrayInputStream.read(buffer)) != -1) {
                dataOutputStream.write(buffer, 0, count);
                dataOutputStream.flush();
            }
        }
        finally
        {
            dataOutputStream.close();
        }
    }
    finally
    {
        byteArrayInputStream.close();
    }

请注意，关闭 ByteArrayInputStream 并不是绝对必要的，但代码有变异的习惯，总有一天输入流可能会变成需要显式关闭的东西。