serverconn.java

来自「农业银行ATM对帐查询系统后台类包的源代码,实现了FTP,数据库管理等等功能」· Java 代码 · 共 73 行

package boco.transmonitor.fmlsocket;

//******************************************************************************
//:功能:
//:时间:2002-07
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//
//******************************************************************************

import java.net.*;
import java.io.*;
import java.util.*;
//****************************************************************************
//类名称：后台监控服务器的客户连接线程
//类功能：实现每个客户连接的线程
//****************************************************************************
public class ServerConn {
protected DataOutputStream outStream=null;
protected Socket clientSocket;
protected FmlServer server;
protected UserThread reader;
//***************************************************************************
//方法名称：构造函数
//方法功能：初始化客户线程连接
//***************************************************************************
  public ServerConn(FmlServer server,Socket clientSocket) {
      try{
            this.server=server;
            this.clientSocket=clientSocket;
            outStream=new DataOutputStream(clientSocket.getOutputStream());
            reader=new UserThread(server,clientSocket);
            reader.start();
        }
      catch(Exception e){
            System.out.println("初始化连接出错:"+e.toString());
        }
  }
//**************************************************************************
//方法名称：发送字符串
//方法功能：向客户发送信息
//**************************************************************************
  public synchronized void sendString(String str)
  {
        if(str==null)
        {
          disconnection();
          return;
        }
        try{
            outStream.writeUTF(str);
        }
        catch(Exception e){
            e.printStackTrace();
            disconnection();
            return;
        }
  }
//***************************************************************************
//方法名称：关闭客户线程
//方法功能：通过关闭UserThread实例关闭线程
//****************************************************************************
  public synchronized void disconnection(){
      try{
            reader.closeConnection();
      }
      catch(Exception e){
            System.out.println("关闭线程出错:"+e.toString());
      }
      reader.destroy();
  }
}