我有一个 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 来调度计时器。知道如何解决吗?
最佳答案
你的类实际上并不是单例类。 按如下方式更改 getInstance 方法(关键字synchronized很重要)。
public static synchronized ClockTask getInstance()
{
if(instance == null)
{
instance = new ClockTask();
}
return instance;
}
并将构造函数设置为私有(private),以防止从外部创建对象。
关于java - Java 中的客户端-服务器应用程序 - 单例问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27766145/