main.java

国外的一个开源gps模拟器源代码

/*
 * Copyright (c) 2007 by the University of Applied Sciences Northwestern Switzerland (FHNW)
 * 
 * This program can be redistributed or modified under the terms of the
 * GNU General Public License as published by the Free Software Foundation.
 * This program is distributed without any warranty or implied warranty
 * of merchantability or fitness for a particular purpose.
 *
 * See the GNU General Public License for more details.
 */

package ch.fhnw.imvs.gpssimulator;

import java.awt.BorderLayout;
import java.awt.Font;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import javax.bluetooth.BluetoothStateException;
import javax.bluetooth.LocalDevice;
import javax.bluetooth.UUID;
import javax.microedition.io.Connector;
import javax.microedition.io.StreamConnection;
import javax.microedition.io.StreamConnectionNotifier;
import javax.swing.BoxLayout;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;

import ch.fhnw.imvs.gpssimulator.components.*;
import ch.fhnw.imvs.gpssimulator.data.GPSData;
import ch.fhnw.imvs.gpssimulator.nmea.GGA;
import ch.fhnw.imvs.gpssimulator.nmea.GLL;
import ch.fhnw.imvs.gpssimulator.nmea.GSA;
import ch.fhnw.imvs.gpssimulator.nmea.NMEASentence;
import ch.fhnw.imvs.gpssimulator.nmea.RMC;

public class Main {
	
	private static final UUID   SERVICE_UUID = new UUID("0000110100001000800000805f9b34fb", false);
	private static final String SERVICE_NAME = "GPSSimulator";
	private static final String SERVICE_URL  = "btspp://localhost:" + SERVICE_UUID 
		+ ";name=" + SERVICE_NAME 
		+ ";authorize=false;authenticate=false;encrypt=false";

	private static StreamConnectionNotifier connectionNotifier;
	private static boolean closing = false;
	
	private static BluetoothPanel bluetooth;
	
   	private static List<NMEASentence> nmeaTypes = new ArrayList<NMEASentence>();


	public static JFrame createFrame() throws IOException {
		JFrame f = new JFrame("GPS Simulator");
    	f.setLayout(new BorderLayout());
     	
		f.addWindowListener(new WindowAdapter() {
			@Override
			public void windowClosing(WindowEvent e) {
				try {
					closing = true;
					connectionNotifier.close();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
				System.exit(0);
			}
		});

    	JPanel box = new JPanel();
    	box.setLayout(new BoxLayout(box, BoxLayout.Y_AXIS));
    	
    	nmeaTypes.add(new GGA());
    	nmeaTypes.add(new GSA());
    	nmeaTypes.add(new RMC());
    	nmeaTypes.add(new GLL());
    	
    	box.add(new GeneralPanel(nmeaTypes));	// add general component
    	box.add(new LocationPanel());			// add location component
    	box.add(new CoursePanel());				// add course component
    	box.add(new QualityPanel());				// add quality component
    	box.add(new XMLPanel());					// add XML waypoints component

    	bluetooth = new BluetoothPanel();
    	box.add(bluetooth);

    	f.add(box, BorderLayout.CENTER);
    	
    	JLabel title = new JLabel("GPS Simulator", JLabel.CENTER);
    	title.setFont(new Font(null, Font.BOLD, 18));
    	f.add(title, BorderLayout.NORTH);
    	
    	GPSData.start();

    	return f;
	}

	static void startListener() throws IOException {
    	try {
    		LocalDevice local = LocalDevice.getLocalDevice();
    		
    		System.out.println("Bluetooth address: " + local.getBluetoothAddress());
    		
        	connectionNotifier = (javax.microedition.io.StreamConnectionNotifier)Connector.open(SERVICE_URL);
    		System.out.println("Service " + SERVICE_URL + " started.");

    		while(true) {
	    		System.out.println("waiting for connections...");
	        	StreamConnection streamConnection = connectionNotifier.acceptAndOpen();
			
				System.out.println("Connection accepted.");
				ConnectionHandler connection = new ConnectionHandler(streamConnection);
				bluetooth.addConnection(connection);

				Thread t = new Thread(connection);
				t.start();
	        }
    	} 
    	catch (BluetoothStateException e) {
    		System.out.println("Error: No Bluetooth device available.");
    		System.exit(1);
    	}
    	catch (IOException e){
    		if(!closing){
    			e.printStackTrace();
    			System.exit(1);
    		}
    	}
	}

    public static class ConnectionHandler implements Runnable {
    	
    	private StreamConnection streamConnection;
    	private DataOutputStream dos = null;
        private volatile boolean running = true;
        private volatile int connectionNumber;
        private volatile static int globalConnectionNumber = 0;
        
        private synchronized static int getGlobalConnectionNumber() {
        	return globalConnectionNumber++;
        }
        
    	public ConnectionHandler(StreamConnection streamConnection) {
    		super();
    		this.connectionNumber = ConnectionHandler.getGlobalConnectionNumber();
    		this.streamConnection = streamConnection;
    	}
    	
    	public int getConnectionNumber() {
    		return connectionNumber;
    	}
    	
    	@Override
		public String toString() {
    		return "" + connectionNumber;
    	}
    	
    	public void stopRunning() {
    		running = false;
    	}
    	
    	public void run() {
    	    try {
    			dos = new DataOutputStream(streamConnection.openDataOutputStream());
    			
    			while(running) {
					try {
						Thread.sleep(1000);
					} 
					catch (InterruptedException e) {
					}
					
					for(NMEASentence s : nmeaTypes){
						if(s.isLinePrinted()){
							writeString(s.getSentence());
						}
					}
    			}
    		} 
    	    catch (IOException e1) {
    			try {
					streamConnection.close();
				} 
    			catch (IOException e2) { }
    			bluetooth.removeConnection(this);

                System.err.println("Connector: " + e1);
                System.err.println("Removing this client from delivery!");
    		}
    	}    

        private void writeString(String string) throws IOException {
            dos.write('$'); 
            dos.write(string.getBytes()); 
            dos.write('\r'); 
            dos.write('\n'); 
            dos.flush();
            System.out.println("$"+string);
        }
    }
    
	public static void main(String[] args) throws Exception {
		JFrame f = createFrame();
		f.pack();
    	f.setResizable(false);
     	f.setVisible(true);
    	
    	startListener();
	}
}