如何为多线程 Java 服务器实现观察者设计模式？

Question

我有以下情况：

一个Java 服务器必须通过套接字响应多个客户端。服务器响应实际上是数据库查询的结果。客户端也可以要求服务器更新数据库内容。

为每个新连接的客户端分配一个新线程。当其他客户端更新数据库内容时，我希望每个连接的客户端 "know"。

我试图实现观察者设计模式来实现这一点，但我没有成功：当对数据库应用更新查询时，观察者不会收到通知 -> 永远不会调用观察者中的更新方法。实际的 Java 代码比较复杂，所以我将尝试通过以下代码片段来总结 Observer 设计模式的实现：

public class DBDataPersistance<E> extends Observable implements DataPersistance<E>{
private static Connection conn;
protected Statement stmt;
protected ResultSet res;
protected List<Observer> obs = new LinkedList<Observer>();

//The method that alters the database;
public void updateData(String parameters) {
    try {
        this.setChanged();
        this.notifyObservers();
        this.stmt.executeUpdate(parameters);
    } catch (SQLException e) {
        JOptionPane.showMessageDialog(null, e.getMessage());
    }
}

public void addObserver(Observer o){
    System.out.println("New observer added!");
    this.obs.add(o);
    }
}

//MultiThreadServer implements Runnable and Observer and contains an instance of DBDataPersistance
public class PizzaMultiThreadServer implements Runnable, Observer{
    private static PizzaDBDataPersistance sDB;
    private static ObjectOutputStream sendClientResponse;
    private static ObjectInputStream isc;


    MultiThreadServer(Socket s) {
        this.cSocket = s;
        try {
            sendClientResponse = new ObjectOutputStream(cSocket.getOutputStream());
            sendClientResponse.flush();
            isc = new ObjectInputStream(cSocket.getInputStream());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }


    public static void main(String[] args) {
    sDB = new DBDataPersistance("jdbc:sqlserver://LAPTOPPC;database=BD;integratedSecurity=true;");
        while (true) {
             //client-server communication
             MultiThreadServer newClient = new MultiThreadServer(csock);
             sDB.addObserver(newClient);
             Thread t = new Thread(newClient);
             t.start();
        }
    }


 @Override
 public void run() {
 //Client server communication on a separate thread
 }


 @Override
 public void update(Observable o, Object arg) {
         System.out.println("Thread " + Thread.currentThread().getId()+ ":Noticed on update!");
 }
}

你能告诉我我哪里错了，并指出在这种情况下正确实现观察者设计模式的步骤吗？

非常感谢。

Answer 1

不要自己实现，有很多库可以帮助你。

我建议https://github.com/ReactiveX/RxJava

（不确定这应该是答案还是评论，对此感到抱歉）

Answer 2

你的问题是因为你 override class DBDataPersistance 中的方法 addObserver 所以你没有 Observers 注册进入 class Observable 所以你没有 Observer 可以被通知。

代码应该是：

public void addObserver(Observer o){
    // Calls the method addObserver of the class Observable
    super.addObserver(o);
    System.out.println("New observer added!");
    this.obs.add(o);
}

请注意，您不需要自己管理 Observer 的列表，因为它已经由 class Observable 管理，所以您应该删除 obs，代码将是：

 public void addObserver(Observer o){
    // Calls the method addObserver of the class Observable
    super.addObserver(o);
    System.out.println("New observer added!");
}

关于您的代码的最后一句话是，您应该在通知 Observers 之前调用 executeUpdate，因此它应该是：

public void updateData(String parameters) {
    try {
        this.stmt.executeUpdate(parameters);
        this.setChanged();
        this.notifyObservers();        
    } catch (SQLException e) {
        JOptionPane.showMessageDialog(null, e.getMessage());
    }
}

如何为多线程 Java 服务器实现观察者设计模式？

How do I implement Observer design pattern for a Multi-Threaded Java server?

java

database

multithreading

observer-pattern