VisClient/org/hfbk/vis/RS232Listener.java

Go to the documentation of this file.

package org.hfbk.vis;


import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.LinkedList;
import java.util.List;

public class RS232Listener extends Thread {

        public static RS232Listener instance=new RS232Listener();
        
        RandomAccessFile com;
        
        public static interface Handler{
                void handleRS232(RS232Listener listener, String msg);
        }
        
        List<Handler> handlers=new LinkedList<Handler>();
        
        RS232Listener() {
                super("RS232Listener"); //name this thread
                setDaemon(true);
                
                try {
                        com=new RandomAccessFile("COM1:38400,N,8,1","rw");
                } catch (FileNotFoundException e) {
                        throw new RuntimeException(e);
                }
                start();
        }

        public void run() {
                print("/");
                try{
                        do{
                                String  msg = com.readLine();
                                System.out.print("RS232 in:"+msg);                      
                                //out.println("/000");
                                if (check (msg)){
                                        System.out.println(" OK.");                     
                                                
                                        String[] parts=msg.split("/");
                                        msg=parts[0];
                                        for (Handler h: handlers)
                                                h.handleRS232(this, msg);
                                        
                                }else
                                        System.out.println();
                        }while(true);
                } catch (IOException e) {
                        e.printStackTrace();
                }       
        }
        
        
        
        static int checksum(String msg){
                int sum=0;
                byte[] b=msg.getBytes();
                for (int i=0; i<msg.length(); i++)
                        sum+=b[i];
                return (sum & 0xFF);
        
        }
        static boolean check(String msg){
                String[] parts=msg.split("/");
                if (parts.length<2) return false;
                parts[0]+="/";
                int sum=checksum(parts[0]);
                return (sum==Integer.parseInt(parts[1]));
        }
        
        static String addChecksum(String s){
                int cs=checksum(s);
                return String.format(s+"%03d", cs);
        }
        
        public void print(String msg){
                try {
                        com.writeChars(addChecksum(msg));
                } catch (IOException e) {
                        e.printStackTrace();
                }
                
                System.out.println("RS232out:"+addChecksum(msg));
        }
        
        public static void main(String[] args) {
                RS232Listener.instance.run();           
        }

        public void addHandler(Handler h) {
                handlers.add(h);
        }
}

---