__pushserver.java~1~

一个简单的GPS服务器程序,用来向客户端发送GPS位置信息,还可用于在模拟环境下对GPS客户端进行测试

package webgis.gpsserver;

import java.io.*;
import java.net.*;
import javax.servlet.*;
import webgis.server.service.*;
import javax.xml.transform.*;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import org.w3c.dom.*;
import org.jdom.*;
import javax.xml.parsers.*;

public class PushServer extends Thread{
  private Log log = LogFactory.getLog("WebGIS");
  private ServletContext servContext;
  private ServerSocket serverSocket;
  private PrintWriter socketOutput;
  private DataInputStream socketInput;
  private BufferedReader keyBoardIn;

  public PushServer(){
    try{
      serverSocket = new ServerSocket(7000);
      this.servContext = servContext;
      log.debug("PushServer Start...");
      this.start();
    }catch(Exception e){
      log.error(e);
    }
  }

  //======== 发送数据到Gps客户端 =========
  public void send(String fileName) {
    String XMLString = null;
    log.debug("发往GPS客户端的协议: "+XMLString);
  }

  private String receive() {
    return null;
  }

  public void run(){
    while (true) {
      try {
        Socket socket = serverSocket.accept();
        socketInput = new DataInputStream(socket.getInputStream());
        keyBoardIn = new BufferedReader(new InputStreamReader(System.in));
        socketOutput = new PrintWriter(socket.getOutputStream(), false);
        while (true) {
          String ProString = socketInput.readLine();
          log.debug(ProString);
          if(ProString == null)continue;
          if (ProString.length() == 0) {
            socketOutput.println("HTTP/1.1 200 OK");
            socketOutput.println("Content-Type: text/html; charset=GB2312");
            socketOutput.println("Date: Sun, 27 May 2008 06:32:24 GMT");
            socketOutput.println("Server: Apache Tomcat/4.0.6 (HTTP/1.1 Connector)");
            socketOutput.println("Transfer-Encoding: chunked");
            socketOutput.flush();

            socketOutput.println("5");
            socketOutput.println("aaaaa");
            socketOutput.println("2");
            socketOutput.flush();

            socketOutput.println("e");
            socketOutput.flush();
          }
        }
      }
      catch (Exception e) {
        log.error(e);
      }
    }
  }

  public static void main(String args[]){
    new PushServer();
  }
}