Hibernate Entity Listeners 和 netty-socketio 之间的调解

Question

我正在做一个小的 Java 项目，这里是我想要实现的基本想法：我在 netty-socketio 上有一个层，它接受来自 socket.io 的请求浏览器，我使用 JPA 2.1/hibernate 将请求的更改保存到数据库。不同之处在于我也有流请求的概念，因为用户将请求集合的当前状态和所有未来的更新。为了从数据库获取实时更新，我使用了实体监听器。我正在寻找一种将实体侦听器方法连接到 socketio 连接之上的处理程序的可靠方法，即当流处理程序感兴趣的数据发生变化时应该通知它，以便它可以将更新发送到管道。我试图想出一个实体侦听器可以 post 更新的单例调解器，订阅的处理程序可以使用它，所有这些都基于 String topic，非常像 pubsub。我遇到的问题是：让我们以 POJO User 为例。当插入一个新的 user 时，UserEntityListener#PostInsert 启动，并通过 .publish 调用将 user 转发给 Notifier。 Notifier 使用 <?> 作为数据类型，它通过类似 Callable 的接口调用相关方：

public interface Notifiable {
    public <T> void onEvent(T data);
}

所以现在在适当的处理程序中调用了它的实现，但它具有通用类型，我必须手动转换它（处理程序知道它应该接收的类型）。我的问题是，我可以在没有显式转换的情况下这样做吗？是否有一个好的框架可以让所有这些低级的修补变得毫无用处？我想要一个集中的解决方案来弥合差距，否则所有的样板文件都会让我丧命。

编辑添加了相关来源。

通知程序class:

class Subscriber {
    public String topic;
    public Notifiable notifiable;
    public Subscriber(String topic, Notifiable n) {
        this.topic = topic;
        this.notifiable = n;
    }
}

public class Notifier {
    private static Notifier instance = null;
    private List<Subscriber> subscribers = new ArrayList<Subscriber>();

    public Notifier() {};
    public void subscribe(String topic, Notifiable n) {
        if (!this.hasSubscriber(topic, n)) {
            this.subscribers.add(new Subscriber(topic, n));
        }
    }
    public <T> void publish(String topic, T data) {
        for (Subscriber s : this.subscribers) {
            if (s.topic.equals(topic)) {
                s.notifiable.onEvent(data);
            }
        }
    }
    public Boolean hasSubscriber (String topic, Notifiable n) {
        for (Subscriber s : this.subscribers) {
            if (s.topic.equals(topic) && s.notifiable == n) {
                return true;
            }
        }
        return false;
    }

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

实体侦听器：

@PostPersist
public void PostInsert(User u) {
    Notifier.getInstance().publish("user/new", u);
}

Socketio 处理程序：

Notifier.getInstance().subscribe("user/new", (new Notifiable() {
    @Override
    public <T> void onEvent(T data) {
        User u = (User) data;
        logger.info("User name: " + u.getUsername());
    }
}));

Answer 1

如果您想避免显式转换，请进行以下更改：

一，使您的 Notifiable 接口通用：

public interface Notifiable<T> {
    public void onEvent(T data);
}

二、让订阅者class也通用：

public class Subscriber<T> {
    public String topic;
    public Notifiable<T> notifiable;
    public Subscriber(String topic, Notifiable<T> n) {
        ...
    }
 }

三、适配Notifierclass

public class Notifier {
    private static Notifier instance = null;

    @SuppressWarnings("rawtypes")
    private List<Subscriber> subscribers = new ArrayList<Subscriber>();

    public Notifier() {};

    public <T> void  subscribe(String topic, Notifiable<T> n) {
        if (!this.hasSubscriber(topic, n)) {
            this.subscribers.add(new Subscriber<T>(topic, n));
        }
    }

    @SuppressWarnings("unchecked")
    public <T> void publish(String topic, T data) {
        for (Subscriber<T> s : this.subscribers) {
            if (s.topic.equals(topic)) {
                s.notifiable.onEvent(data);
            }
        }
    }

    @SuppressWarnings("unchecked")
    public <T> Boolean hasSubscriber (String topic, Notifiable<T> n) {
        for (Subscriber<T> s : this.subscribers) {
           /* XXX: Beware, is safe to compare two notifiable
            * instances by their memory addresses??
            */
           if (s.topic.equals(topic) && s.notifiable == n) {
                return true;
           }
        }
        return false;
    }

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

四、Socketio Handler：

Notifier.getInstance().subscribe("user/new", (new Notifiable<User>() {
    @Override
    public void onEvent(User data) {
        logger.info("User name: " + u.getUsername());
    }
}));

Hibernate Entity Listeners 和 netty-socketio 之间的调解

Mediation between Hibernate Entity Listeners and netty-socketio

java

hibernate

hibernate-entitymanager

socket.io

jpa-2.1