java-J2ME-无法在客户端关闭输出流,服务器在等待数据时挂起[诺基亚J2ME实现]

我的问题是：有没有一种方法可以执行套接字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编码一无所知,我丢失了一些东西,或者它可能类似于某种诺基亚J2ME编码标准,我应该习惯它或更改平台)

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

看起来像这样：J2ME客户端-> J2SE服务器(由于客户端未执行输出流关闭而处于读取挂起状态)-> J2ME

我试图：
在J2ME客户端上关闭dataOutputStream-无效
setSocketOptions(KEEPALIVE,SNDBUF等)-无效或错误

在目标设备上似乎没有任何作用

抱歉,但是在与小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();

解决方法:

使用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,但是代码具有更改的习惯,并且有一天,输入流可能会变成需要显式关闭的内容.

标签：sockets,java-me,nokia,java
来源： https://codeday.me/bug/20191201/2080537.html