brokerserver.java

一个可以实现联网售票的火车售票管理系统

package train.server;

import java.net.*;
import java.io.*;
import train.command.*;
import train.mvc.Model;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: 沈阳化工学院计算机</p>
 *
 * @author 彭胜勇 胡林
 * @version 1.0
 */
public class BrokerServer implements IoStrategy {
    Model model;
    public BrokerServer(Model model) {
        this.model = model;
    }

    public void ioService(Socket skt) {
        InputStream is = null;
        OutputStream os = null;
        ObjectInputStream ois = null;
        ObjectOutputStream oos = null;
        try {
            is = skt.getInputStream();
            os = skt.getOutputStream();
            ois = new ObjectInputStream(is);
            oos = new ObjectOutputStream(os);
            while (true) {
                Object obj = ois.readObject();
                if (obj instanceof Command) {
                    Command com = (Command) obj;
                    com.setModel(model);
                    com.execute();
                    oos.writeObject(com);
                } else {
                    oos.writeObject(new Exception("Refuse to service !" + obj));
                }
            }
        } catch (Exception e) {
            System.out.println("End of Servicing ." + skt.getInetAddress());
        }
    }
}