src2011-

简单上位机软件

import java.io.*;
import java.util.*;
import javax.comm.*;
import javax.swing.JFrame;

public class Read implements Runnable, SerialPortEventListener {
     static CommPortIdentifier portId;
     static Enumeration portList;
     public static String sends="";
    InputStream inputStream;
    OutputStream outputStream;
    SerialPort serialPort;
    Thread readThread;
	Thread writeThread;
     public Thread r;
     public Write ro;
     static JFrame f;
     static Win win;
   // static boolean read=false,write=false;
    
    public static void main(String[] args) {
    	win=new Win();
    	f=win.getJFrame();
    	f.setVisible(true);
    	
        portList = CommPortIdentifier.getPortIdentifiers();

        while (portList.hasMoreElements()) {
            portId = (CommPortIdentifier) portList.nextElement();
            if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                if ((portId.getName().equals("COM1"))) {
                	
                    Read m=new Read();
                }
            }
        }
       
    }
    public Read(){

        try {
            serialPort = (SerialPort) portId.open("SimpleReadApp", 2000);
        } catch (PortInUseException e) {
        	e.printStackTrace();
        }
        try {
            inputStream = serialPort.getInputStream();
            outputStream=serialPort.getOutputStream();
        } catch (IOException e) {e.printStackTrace();}
        try {
            serialPort.addEventListener(this);
        } catch (TooManyListenersException e) {e.printStackTrace();}
        	serialPort.notifyOnDataAvailable(true);
        try {
            serialPort.setSerialPortParams(38400,
                SerialPort.DATABITS_8,
                SerialPort.STOPBITS_1,
                SerialPort.PARITY_EVEN);
        } catch (UnsupportedCommOperationException e) {e.printStackTrace();}
          readThread=new Thread(this);
          ro=new Write();
          ro.outputStream=outputStream;
          writeThread=new Thread(r);
          readThread.start();
          writeThread.start();
    }
   
    public void run() {

    			try {
    				Thread.sleep(20000);
    			} catch (InterruptedException e) {e.printStackTrace();}
    	
    }
   

    public void serialEvent(SerialPortEvent event) {
        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.toString());
            break;
        case SerialPortEvent.DATA_AVAILABLE:
            byte[] readBuffer = new byte[20];

            try {
                while (inputStream.available() > 0) {
                    inputStream.read(readBuffer);
                }
                String getS=Util.Bytes2HexString(readBuffer);
               win.getJTextArea().append("接收："+getS+"\n");
            } catch (IOException e) {}
            break;
        }
    }
}