java_chuankou.rar_java串口通信_pc串口_串口_串口 java_串口通信JAVA

import java.io.*; import java.util.*; import javax.comm.*; import java.awt.*; import javax.swing.*; import java.awt.event.*; class com extends JFrame implements ActionListener,SerialPortEventListener{ static Enumeration portList;//枚举类型 static CommPortIdentifier portId;/* 检测系统中可用的通讯端口类 */ static SerialPort serialPort;/* 声明RS-232串行端口的成员变量 */ static OutputStream outputStream;//输出流 static InputStream inputStream;//输入流 static boolean use=false; //用来判断串口是否在使用 static boolean flag=true; JPanel panel; JScrollPane scrollPane; JTextField text=new JTextField(); JButton send=new JButton("发送/打开串口"); JButton cle=new JButton("清除"); JTextArea area=new JTextArea(); JLabel label=new JLabel("发送信息"); String message; com(){ this.setDefaultCloseOperation(EXIT_ON_CLOSE); subpanel(); } public void subpanel(){ panel=(JPanel)getContentPane(); panel.setLayout(null); scrollPane=new JScrollPane(area); label.setBounds(35,30,80,25); text.setBounds(120,30,150,25); send.setBounds(290,30,120,23); cle.setBounds(280,335,80,25); scrollPane.setBounds(35,70,340,250); area.setFont(new Font("",Font.PLAIN,14));//设置字体大小 panel.add(label); panel.add(text); panel.add(send); panel.add(cle); panel.add(scrollPane); send.addActionListener(this);//添加监听 cle.addActionListener(this); } public void actionPerformed(ActionEvent e) { if(e.getSource()==send) //发送按钮事件判断 { message=text.getText();//将text中的文本赋予message System.out.println(message); open(); //调用open方法，主要是打开串口 } if(e.getSource()==cle) area.setText(null); } public void open(){ boolean portFound=false; boolean bukong=false; String defaultPort="COM1"; portList=CommPortIdentifier.getPortIdentifiers();//获得所有通信端口 while(portList.hasMoreElements())// 测试此枚举是否包含更多的元素 { portId=(CommPortIdentifier)portList.nextElement();//返回此枚举的下一个元素 if(portId.getPortType()==CommPortIdentifier.PORT_SERIAL)//判断是否串口 { if(portId.getName().equals(defaultPort))//判断是否COM1 { portFound=true; // 发现了串口 if(!use) //如果串口没被使用。就进行以下的操作 { try { serialPort=(SerialPort)portId.open("com",2000);//打开串口 area.setText("串口"+portId.getName()+"已经打开\n"); } catch(PortInUseException a){ System.out.print("端口正在使用");//消息框 return; } } try { outputStream=serialPort.getOutputStream();//设置输出流 } catch(IOException a){} try { serialPort.setSerialPortParams(9600,//设置串口通信参数 SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); } catch(UnsupportedCommOperationException a){} try { area.append("\n"); outputStream.write(message.getBytes());//将数据写入输出流 if(message.length()>0) //如果点击发送按钮是消息框不为空,才显示 { area.append("输出: "+message+"\n"); bukong=true; } use=true; } catch(IOException a){} } } } try { inputStream=serialPort.getInputStream();//设置输入流 if(bukong){ area.append("输入: "); } } catch(IOException a){} try { serialPort.addEventListener(this);//添加串口监听 } catch(TooManyListenersException a){} serialPort.notifyOnDataAvailable(true); } public void serialEvent(SerialPortEvent event)//实现串口监听中的方法 { byte[] readBuffer=new byte[1]; try { while(inputStream.available()>-1) { // int numBytes=inputStream.read(readBuffer);//从输入流每次读取一个字节的数据 area.append(new String(readBuffer));//将下一个数据追加到尾部 } } catch(Exception e){ } } }