connection.java

来自「一个agent 工具包,可以开发移动设备应用,考虑了安全措施」· Java 代码 · 共 73 行

package SOMA.network.connection;

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

import SOMA.Environment;

/** Demone responsabile delle comunicazioni via socket con un altro place.
* @see SOMA.network.connection.NewClientExplorerItem
*
* @author Livio Profiri
*/
public class Connection implements Daemon, Runnable
{
  Thread myDaemon = null;
  Socket mySocket = null;
  ObjectInputStream myObjectInputStream = null;
  ObjectOutputStream myObjectOutputStream = null;

  //BufferedInputStream bis = null;

  Object status = OFF;

  String ErrorDescription = "";

  Environment env = null;

  /** Costruttore vuoto. */
  protected Connection()
  {}

  /** Costruttore: effettua le inizializzazioni ed apre gli stream della socket.
  * @param mySocket Socket utilizzata per le comunicazioni.
  * @param env Riferimento all'environment del place.
  */
  public Connection( Socket mySocket, Environment env )
  {
    this.mySocket = mySocket;
    this.env = env;
    try
    {
      myObjectOutputStream = new ObjectOutputStream( mySocket.getOutputStream() );
      myObjectInputStream = new ObjectInputStream( mySocket.getInputStream() );
      //bis = new BufferedInputStream( mySocket.getInputStream() );
      //myObjectInputStream = new ObjectInputStream( bis );
    }
    catch( IOException e )
    {
      status = ERROR;
      ErrorDescription = e.toString();
    }
  }

  /** Restituisce l'input stream della socket.*/
  public InputStream getIn()
  {
    return myObjectInputStream;
  }

  /** Restituisce l'output stream della socket.*/
  public OutputStream getOut()
  {
    return myObjectOutputStream;
  }


  /** restituisce lo stato della connessione. */
  public Object getStatus()
  {
    return status;
  }

  // Attenzione: necessariamente non si potr