Java教程

java tcp socket readline 阻塞问题处理

本文主要是介绍java tcp socket readline 阻塞问题处理,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

背景:项目需要对接物联网设备,要求用TCP SOCKET 设备的服务端,设备自动上报自身状态及指标数据等信息。

问题:提交参数后,读取服务端的BufferedReader,一直卡在read line那里,一直等到一分多钟才读取到。

分析:既然能读取到,说明提交参数和连接等是没有问题的,问题就出在读取这里。还是在网上搜索解决方法,更改为字节读取,不使用行读取,问题解决。大概是服务端写根本就没有一行一行的写。

代码如下:

 @Test
    void test5() throws IOException {
        InetSocketAddress inetSocketAddress = new InetSocketAddress
                ("", 10965);
        Socket socket = new Socket();
        System.out.println("开始连接socket服务器");
        socket.connect(inetSocketAddress);
        if (socket.isConnected()) {
            System.out.println("服务器连接成功");
        } else {
            System.out.println("服务器连接失败");
            return;
        }
        System.out.println("开始写入数据");
        OutputStream os = socket.getOutputStream();//字节输出流
        PrintWriter pw = new PrintWriter(os);//将输出流包装成打印流
        String parm = "{\n" +
                "    \"CMD\":\"CSREG\",\n" +
                "    \"Token\":4,\n" +
                "    \"CsEUI\":\"626F6373bb46da52\",\n" +
                "    \"AppNonce\":292657,\n" +
                "    \"Challenge\":\"ABCDEF1234567890ABCDEF1234292657\"\n" +
                "}\0";
        System.out.println("数据:" + parm);
        pw.write(parm);
        pw.flush();
        System.out.println("数据写入完成,开始读取数据");
        InputStream is = socket.getInputStream();
        byte[] b = new byte[1024];
        int x = is.read(b, 0, b.length);
        String string = new String(b, 0, x);
//        BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
//        String info = br.readLine();
        System.out.println("服务器:" + string);
        System.out.println("执行完成");
//        br.close();
        is.close();
        pw.close();
        os.close();
        socket.close();
    }

 

这篇关于java tcp socket readline 阻塞问题处理的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!