zoukankan      html  css  js  c++  java
  • 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 project 和 java web project 获取路径问题
    java.lang.UnsupportedClassVersionError: *** : Unsupported major.minor version 51.0
    Hibernate Annotation (Hibernate 注解)
    远程访问(post 传参数) 以及IOUtils复制文件
    使用jdk中keytool生成证书
    Chrome 的滚动条修改.
    https原理及tomcat配置https方法
    HttpClient 访问 https 出现peer can't
    Dom4j解析xml
    Tomcat Server 配置
  • 原文地址:https://www.cnblogs.com/rolayblog/p/15599131.html
Copyright © 2011-2022 走看看