java - Java 中的客户端-服务器应用程序 - 单例问题

Question

我有一个 Java 客户端-服务器时钟应用程序。服务器将时间数据发送到所有连接的客户端，每个连接都在单独的线程上运行。定时事件由ClockTask管理，它是单例的，这样所有的连接线程都可以访问同一个服务器时间:

public class ClockTask extends TimerTask {

private Calendar calendar;
private String time;
private static ClockTask instance = null;


public static ClockTask getInstance()
{
    if(instance == null)
    {
        return new ClockTask();
    }
    else return instance;
}

public String getTime() {
    return time;
}


public void setTime(String time) {
    this.time = time;
}


public ClockTask()
{
    this.calendar = Calendar.getInstance(new Locale("us", "US"));

}


@Override
public void run() {

    calendar.add(Calendar.SECOND, 1);
    DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");                   
    this.time = dateFormat.format(calendar.getTime());
    //System.out.println(time);
}


public void setCalendarTime(String newTime)
{
    DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");   
    try {
        Date t = dateFormat.parse(newTime);
        calendar.setTime(t);

    } catch (ParseException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}



}

现在，如果客户端发送更改服务器时间的请求，则可以正常工作。服务器设置新时间，所有连接的客户端都会获得新的更新时间。我不明白的是，为什么如果我连接一个新客户端(设置新时间后)，新客户端再次具有当前时间，并且服务器将其时间重置为新连接的客户端之一。

我的服务器代码及其连接线程:服务器无限循环，等待新的客户端，如果客户端连接到套接字，它将启动一个新线程。

 public class Server {



 public static void main(String[] args) throws IOException {

        ServerSocket serverSocket = null;

        boolean listeningSocket = true;

        try {
            serverSocket = new ServerSocket(11111);
        } catch (IOException e) {
            System.err.println("Could not listen on port: 11111");
        }


        while(listeningSocket){

            System.out.println("Waiting for a client to connect...");
            Socket clientSocket = serverSocket.accept();
            System.out.println("Client connected!");
            ConnectThread ct = new ConnectThread(clientSocket);                     
            ct.start();

        }
        System.out.println("closed");
        serverSocket.close();       
    }

}

连接线程使用现有的 ClockTask 实例来获取和发送当前服务器时间。

public class ConnectThread extends Thread{

public static final int INTERVAL = 1000;

static ClockTask ctask;


private Socket socket = null;
public ConnectThread(Socket socket) {
    super("ConnectThread");
    this.socket = socket;
    ConnectThread.ctask = ClockTask.getInstance();
    System.out.println(ctask.getTime());

}

@Override
public void run(){
    ObjectOutputStream serverOutputStream = null;
    ObjectInputStream serverInputStream = null;
    try {           
        serverOutputStream = new ObjectOutputStream(socket.getOutputStream());          
        serverInputStream = new ObjectInputStream(socket.getInputStream());


        Timer timer = new Timer();
        timer.schedule(ctask, 0, INTERVAL);

        while(true)
        {
            Thread.sleep(INTERVAL);
            System.out.println(ctask.getTime());
            serverOutputStream.writeUTF(ctask.getTime());               
            serverOutputStream.flush();
            String ok = serverInputStream.readUTF();
            if(ok.equals("ok"))
            {

                String newTime = serverInputStream.readUTF();
                ctask.setCalendarTime(newTime);
            }

        }

    } catch (IOException | InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    finally{
        try {
            serverOutputStream.close();
            serverInputStream.close();              
            socket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }       
}
}

客户端读取时间并在 GUI 中更新它。如果用户按下按钮发送时间更改请求，客户端会将新时间发送回服务器，服务器在收到 REQUEST_TIME_CHANGE 字符串后会修改其时间。我真的不明白为什么当新客户端连接时时间会变回来。有什么想法吗？

编辑:

这是现在发生的事情:

Exception in thread "ConnectThread" java.lang.IllegalStateException: Task already scheduled or      cancelled
at java.util.Timer.sched(Unknown Source)
at java.util.Timer.schedule(Unknown Source)
at task2.ConnectThread.run(ConnectThread.java:36)

这可能是因为我多次使用同一个 TimerTask 来调度计时器。知道如何解决吗？

Answer 1

你的类实际上并不是单例类。按如下方式更改 getInstance 方法(关键字synchronized很重要)。

public static synchronized ClockTask getInstance() 
{
    if(instance == null)
    {
        instance = new ClockTask();
    }
    return instance;
}

并将构造函数设置为私有(private)，以防止从外部创建对象。