server.java~3~

使用java实现的计算机自主发短信到手机。 运行界面上

// Server.java
package keti2;

import java.io.*;
import java.net.*;

public class Server extends Thread
{
  public final static int Default_Port=6543;
  protected int port;
  protected ServerSocket listen_socket;
  //add 12.25.04
  public static boolean Server_Flag=true;

  public static Frame1 fframe;

// 定义出错例程：如果出现异常错误，退出程序。
  public static void fail(Exception e, String msg) {
    System.err.println(msg + ": " + e);
    System.exit(1);
  }

// 定义并启动服务器的Socket 例程，监听客户机的连接请求。
  public Server(int port)
  {
    if(port == 0) port = Default_Port;
    this.port = port;
    this.fframe=null;
    try
    {
      listen_socket = new ServerSocket(port);
    }
    catch( IOException e)
    {
      fail(e, "Exception creating server socket");
    }
    System.out.println("Server: listening on port" + port);
    this.start();
  }

  public Server(int port,Frame1 ff)
  {
    if(port == 0) port = Default_Port;
    this.port = port;
    this.fframe = ff;
    try
    {
      listen_socket = new ServerSocket(port);
    }
    catch( IOException e)
    {
      fail(e, "Exception creating server socket");
    }
    System.out.println("Server: listening on port" + port);
    this.start();
  }


/* 下面为服务器监听线程的主程序。该线程一直循环执行，监听并接受客户机发出的连接

请求。对每一个连接，均产生一个连接对象与之对应，通过Socket 通道进行通信。*/

  public void run() {
    try {
      while (Server_Flag) {
        Socket client_socket = listen_socket.accept();
        Connection c = new Connection(client_socket);
      }
      System.out.println("Server:" + port + "is finished");
    }
    catch (IOException e) {
      fail(e, "Exception while listening for connections");
    }
  }

// 启动服务器主程序

  public static void main(String args[]) {
    int port = 0;
    if (args.length == 1) {
      try {
        port = Integer.parseInt(args[0]);
      }
      catch (NumberFormatException e) {
        port = 0;
      }
    }
    new Server(port);
  } // End of the main

  public static void EndServer() {
    Server_Flag=false;
//    Client client
  }

}// End of Server class

//以下定义了Connection 类，它是用来处理与客户机的所有通信的线程。
class Connection extends Thread
{
  protected Socket client;
  protected DataInputStream in;
  protected PrintStream out;

// 初始化通信流并启动线程
  public Connection(Socket client_socket)
  {
    client = client_socket;

    try
    {
      in = new DataInputStream(client.getInputStream());
      out = new PrintStream(client.getOutputStream());
    }
    catch(IOException e)
    {
      try {
        client.close();
      }
      catch(IOException e2){
        ;
      }

      System.err.println("Exception while getting socket streram: " + e);
      return;
    }

    this.start();
  }// End of Connection method

// 服务例程：读出一行文本；反转文本；返回文本。
  public void run()
  {
    String line;
    StringBuffer revline;
    int len;

    try
    {
      for( ; ; )
      {
        // Read a line
        line = in.readLine();
        if (line == null) {
          break;
        }
        System.out.println(line);

        Frame1.sendShortMessage("发现不明物体","13945667841");


        // Reverse the line
        len = line.length();
        revline = new StringBuffer(len);

        for (int i = len - 1; i >= 0; i--) {
          revline.insert(len - 1 - i, line.charAt(i));
        }

        // Write out the reverse line
        out.println(revline);

//        System.out.println(revline);
      }
    }
    catch(IOException e) {
      ;
    }

    try {
      client.close();
    }
    catch (IOException e2){
      ;
    }

  } // End of run method
} // End of Connection class