当前位置: 首页 > 面试题库 >

inputstream.available()始终为0

鲜于渊
2023-03-14
问题内容

我不知道我的代码正在发生什么。我没有错误,也没有回应。我正在将数据写入串行端口,并通过激活等待响应,
port.notifyOnDataAvailable(true);但未触发此事件,inputstream.available()始终返回0。可能是什么问题?我在Linux中使用RXTX。

编辑

package testConn;  
import forms_helper.global_variables;  
import java.io.BufferedReader; 
import java.io.IOException;  
import java.io.InputStream;  
import java.io.InputStreamReader;  
import java.io.OutputStream;  
import java.io.PrintStream;  
import java.io.UnsupportedEncodingException;  
import java.util.logging.Level;  
import java.util.logging.Logger;  
import javax.comm.*;  
import java.util.*;  
/** Check each port to see if it is open. **/   
public class openPort implements SerialPortEventListener {

    static Enumeration portList;
    static CommPortIdentifier portId;
    static String messageString;
    public static SerialPort serialPort;
    static OutputStream outputStream;
    InputStream inputStream;
    static boolean outputBufferEmptyFlag = false;
    private BufferedReader is;
    private PrintStream os;

    public void open() {
        Enumeration port_list = CommPortIdentifier.getPortIdentifiers();

        while (port_list.hasMoreElements()) {
            // Get the list of ports
            CommPortIdentifier port_id = (CommPortIdentifier) port_list.nextElement();
            if (port_id.getName().equals("/dev/ttyS1")) {

                // Attempt to open it
                try {
                    SerialPort port = (SerialPort) port_id.open("PortListOpen", 20000);
                    System.out.println("Opened successfully:"+port);
                    try {
                        int baudRate = 9600; //
                        port.setSerialPortParams(
                                baudRate,
                                SerialPort.DATABITS_7,
                                SerialPort.STOPBITS_1,
                                SerialPort.PARITY_EVEN);
                        port.setDTR(true);


                        port.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);

                        System.out.println("properties are set");
                    } catch (UnsupportedCommOperationException e) {
                        System.out.println(e);
                    }
                    try {
                        //input = new SerialReader(in);
                        port.addEventListener(this);
                        System.out.println("listeners attached" + this);
                    } catch (TooManyListenersException e) {
                        System.out.println("too many listeners");
                    }
                    port.notifyOnDataAvailable(true);

                    //port.notifyOnOutputEmpty(true);
                    //sendMessage(port,"@PL");
                    //port.close ();
                    try {
                        is = new BufferedReader(new InputStreamReader(port.getInputStream()));
                    } catch (IOException e) {
                        System.err.println("Can't open input stream: write-only");
                        is = null;
                    }
                    try {
                        os = new PrintStream(port.getOutputStream(), true);
                    } catch (IOException ex) {
                        Logger.getLogger(openPort.class.getName()).log(Level.SEVERE, null, ex);
                    }

                    try {
                        inputStream = port.getInputStream();
                        System.out.println("inputstream" + inputStream.available());
                        outputStream = (OutputStream) port.getOutputStream();
                        os = new PrintStream(port.getOutputStream(), true, "US-ASCII");


                    } catch (IOException e) {
                        System.out.println(e);
                    }

                    //set the created variables to global variables
                    global_variables.port = port;
                    global_variables.inputStream = inputStream;
                    System.out.println(inputStream);
                    System.out.println(outputStream);
                    global_variables.outputStream = outputStream;
                    global_variables.os = os;
                } catch (PortInUseException pe) {
                    System.out.println("Open failed");
                    String owner_name = port_id.getCurrentOwner();
                    if (owner_name == null) {
                        System.out.println("Port Owned by unidentified app");
                    } else // The owner name not returned correctly unless it is
                    // a Java program.
                    {
                        System.out.println("  " + owner_name);
                    }
                }
            }
        }
    }

    public static void sendMessage(SerialPort port, String msg) {
        if (port != null) {
                System.out.println(msg);
            try {
                byte[] bytes = msg.getBytes("US-ASCII");
                try {
                    global_variables.outputStream.write(bytes);
                    System.out.println(bytes.length);
                    global_variables.outputStream.flush();
                } catch (IOException ex) {
                    Logger.getLogger(openPort.class.getName()).log(Level.SEVERE, null, ex);
                }
            } catch (UnsupportedEncodingException ex) {
                Logger.getLogger(openPort.class.getName()).log(Level.SEVERE, null, ex);
            }
                System.out.println("Opened successfully:"+msg.getBytes());
                //global_variables.outputStream.write(msg.getBytes());
                //global_variables.outputStream.flush();
                //global_variables.os.print(msg);
                System.out.println(global_variables.outputStream);
                try {
                    Thread.sleep(2000);  // Be sure data is xferred before closing
                    System.out.println("read called");
                    //SimpleRead read = new SimpleRead();
                    //int read = global_variables.inputStream.read();
                    //System.out.println("read call ended"+read);
                } catch (Exception e) {
                }

        }
    }

    public void serialEvent(SerialPortEvent event) {
        System.out.println(event.getEventType());
        String line;
                try {
                    line = is.readLine();
                    if (line == null) {
                        System.out.println("EOF on serial port.");
                        System.exit(0);
                    }
                    os.println(line);
                } catch (IOException ex) {
                    System.err.println("IO Error " + ex);
                }
        switch (event.getEventType()) {
            /*
            case SerialPortEvent.BI:

            case SerialPortEvent.OE:

            case SerialPortEvent.FE:

            case SerialPortEvent.PE:

            case SerialPortEvent.CD:

            case SerialPortEvent.CTS:

            case SerialPortEvent.DSR:

            case SerialPortEvent.RI:


            case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
            System.out.println("event.getEventType()");
            break;
             *
             */

            case SerialPortEvent.DATA_AVAILABLE:
                System.out.println("inside event handler data available");
                byte[] readBuffer = new byte[20];


                try {
                    while (inputStream.available() > 0) {
                        int numBytes = inputStream.read(readBuffer);
                    }
                    System.out.print(new String(readBuffer));
                    System.exit(1);
                } catch (IOException e) {
                    System.out.println(e);
                }

                break;
        }
    }
} // PortListOpen

我在主要方法上打开端口,并在应用程序内的按钮单击事件上发送消息。


问题答案:

.available() 不能用于进程间通信(包括串行),因为它仅检查当前进程中(输入缓冲区中)是否有可用数据。

在串行通信中,当您发送一个messaga然后立即呼叫时available(),由于串行端口尚未回复任何数据,因此您通常会得到0。

解决方案是read()在单独的线程中使用阻塞(interrupt()以结束线程):
线程中断未结束对输入流的读取的阻塞调用



 类似资料:
  • 下面是片段。请注意,我已经恢复到以前的提交,因此丢失了最近的修改,但请查看我编写的代码,然后才注意到始终等于0() 以下是当检测到活动后按: 以下是NoteActivity接收结果调用的方式。 null 我在我的项目上浪费了很多重要的时间,只是想知道是什么使resultCode和requestCode的值丢失了我发送的值。 任何帮助和指导都将不胜感激。非常感谢!

  • 我总是用下面的代码得到。 这是我的process代码 但如果coderesultcode正常工作。 这是我的

  • 问题内容: 我正在编写一个C#ASP.Net MVC应用程序,供客户端将文件发布到其他服务器。我正在使用通用处理程序来处理从客户端到服务器的发布文件。但是在我的处理程序中,System.Web.HttpContext.Current.Request.Files始终为空(0个计数)。 表格代码: 处理程序: 请帮我。谢谢。 问题答案: 最后,我发现了问题。 由于某些原因,控制器中的代码永远无法正常工

  • 问题内容: 我使用firefox 3.6.10和firebug进行调试 所以,这是我的代码: responseXML 始终为null,我已经尝试了来自不同域的多个URL。我也异步地尝试过,结果是一样的。该 responseText的 总是正确返回,与它没有任何问题。 我的目标是获取 responseXML.documentElement 。 谢谢你的帮助。 编辑----------- 此javas

  • 问题内容: 士兵级 子弹班 我在碰撞检测方面遇到了麻烦。我已经尝试过Rect.intersects,r.intersect(r1),r.contains(r1),并且始终为false。我什至绘制矩形以确保正确绘制并且正确绘制,但是碰撞始终为假 问题答案:

  • 我有两个不同的活动,在第一个活动中,我在一些EditText中输入一些信息,然后进入第二个活动,但当我返回时,第一个活动中EditText上的文本消失了。 以下是第一个活动的OnCreate() 我正在使用onSaveInstanceState方法保存信息 在进行调试时,我可以看到确实在onSaveInstanceState方法中填充了savedInstanceState捆绑包,但在OnCreat