Java – 从缓冲读取器(从套接字)读取正在暂停线程

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java – 从缓冲读取器(从套接字)读取正在暂停线程，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2333字，纯文字阅读大概需要4分钟。

内容图文

我有一个线程从缓冲读取器读取字符(从套接字创建如下)：

inputStream = new BufferedReader(new InputStreamReader(clientSock.getInputStream()));

此代码只能运行一次.例如,如果客户端连接并发送：
“这是一个测试”和“这是另一个测试”,主机输出是：

 Reading from stream:
 Chars read from stream: 16
 This is a test

 Reading from stream:

请注意,程序不会收到“这是另一个测试”,因为它一直在读取流.有没有办法处理这个而不减少缓冲区大小？
这是线程的代码：

public void run() {
        boolean dataRecieved = false;
        char[] inputChars = new char[1024];
        int charsRead = 0;

        while (!stopNow) {

            try {
                Thread.sleep(getDataDelay);

                //Read 1024 characters. Note: This will pause the thread when stream is empty.
                System.out.println("Reading from stream:");
                charsRead =  inputStream.read(inputChars); //<< THIS LINE IS PAUSING THE THREAD!> 


                if ((charsRead =  inputStream.read(inputChars)) != -1)
                {
                    System.out.println("Chars read from stream: " + charsRead);  
                    System.out.println(inputChars);
                    System.out.flush();
                }


            } catch (IOException e) {
                System.out.println("IOException");
                //TODO: CLIENT HAS DISCONNECTED...
            } catch (InterruptedException e) {
                System.out.println("Interrupted");
                // Sleep was interrupted.
            } 

        }

    }

客户/发件人代码(不是我的代码)：

public static void main(String[] args) throws IOException {
        // <<<<<<<<<<< CLIENT >>>>>>>>>>>>>>>

        Socket sock = new Socket("127.0.0.1", 3000);
        // reading from keyboard (keyRead object)
        BufferedReader keyRead = new BufferedReader(new InputStreamReader(System.in));
        // sending to client (pwrite object)
        OutputStream ostream = sock.getOutputStream(); 
        PrintWriter pwrite = new PrintWriter(ostream, true);

        // receiving from server ( receiveRead  object)
        InputStream istream = sock.getInputStream();
        BufferedReader receiveRead = new BufferedReader(new InputStreamReader(istream));

        System.out.println("Start the chitchat, type and press Enter key");

        String receiveMessage, sendMessage;               
        while(true)
        {
            sendMessage = keyRead.readLine();     // keyboard reading
            pwrite.println(sendMessage);       // sending to server
            System.out.flush();         // flush the data

            if((receiveMessage = receiveRead.readLine()) != null) //receive from server
            {
                System.out.println(receiveMessage); // displaying at DOS prompt
            }         
        }               
    }          

解决方法:

java.io.InputStream.read()是一个阻塞调用,这意味着如果没有数据可用,则线程将停止,直到数据可用.

对于非阻塞I / O,请使用java.nio包中的类.

内容总结

以上是互联网集市为您收集整理的Java – 从缓冲读取器(从套接字)读取正在暂停线程全部内容，希望文章能够帮你解决Java – 从缓冲读取器(从套接字)读取正在暂停线程所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端