brokerserver.java~1~

来自「一个可以实现联网售票的火车售票管理系统」· JAVA~1~ 代码 · 共 41 行

package mvc.server;

import java.net.*;
import java.io.*;
import command.*;
import command.user.*;
import mvc.server.Model;

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());
        }
    }
}