如何从服务器向客户端发送消息？

Question

我将实现类似于 Facebook 通知和此网站的功能（StackOverflow 的通知会通知我们是否有人为我们的问题写评论/答案等）。请注意，用户会将我的应用程序用作网站而非移动应用程序。

我遇到了以下answer 获取结果，但我需要推送结果而不是获取。

根据建议，我在我的实体类中创建了一个简单的方法并向其中添加了@PostPersist，但它没有工作，因此基于this answer 我添加了 persistence.xml 文件来定义侦听器，但在 session.save 之后(用户) aftersave 方法没有被触发。

User.java

@Entity
public class User{
  .....
  @PostPersist
    public void aftersave(){
        System.err.println("*****this is post persist method****");
    }
}

persistence.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<!--
To change this template, choose Tools | Templates
and open the template in the editor.
-->

<property name="hibernate.ejb.event.pre-insert"  value="my.hibernate.events.listeners.Listener" />
<property name="hibernate.ejb.event.pre-update"  value="my.hibernate.events.listeners.Listener" />
<property name="hibernate.ejb.event.pre-delete"  value="my.hibernate.events.listeners.Listener" />
<property name="hibernate.ejb.event.post-insert" value="my.hibernate.events.listeners.Listener" />
<property name="hibernate.ejb.event.post-update" value="my.hibernate.events.listeners.Listener" />
<property name="hibernate.ejb.event.post-delete" value="my.hibernate.events.listeners.Listener" />

pom.xml

 <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-core</artifactId>
            <version>4.2.1.Final</version>
            <type>jar</type>
        </dependency>

Answer 1

听起来像是WebSockets 的任务。它是 Java EE 7 的一部分，因此 Glassfish 应该是第一个支持它的 AS。

要拦截数据库访问，您可以使用@PostUpdate 和@PostPersist。这里是相关的question。

有很多方法可以执行所谓的服务器推送来通知连接的客户端：

• 投票（您在问题中提供的链接（“我们到了吗？我们到了吗？...”））
• long polling（更智能的轮询方式 - 使用 keepalive 消息的长寿命 HTTP 技术）
• WebSockets (JSR 356)
• piggy-backing
• SPDY(wiki)
• Server-Sent Events (related answer, wiki)

编辑：在 Java 世界中，有几个框架可以开箱即用地实现服务器推送（反向 ajax）。如果您熟悉GWT，我建议您使用Errai。其他选择是Atmospere。 Atmospere 的缺点是它需要在您的常规应用程序服务器旁边与您的 Web 应用程序一起独立运行进程。一年前我在玩它，所以从那时起这可能已经改变了。

一般来说，很难为您提供一段具体的代码，因为这取决于您将选择的框架。我对 Errai 很熟悉，所以这里有一个例子：

服务器端：

@ApplicationScoped
public class TickerService {

  @Inject
  private Event<Tick> tickEvent;

  private void sendTick() {
    tickEvent.fire(new Tick());
  }
} 

客户端：

@EntryPoint
public class TickerClient {
  public void tickHappened(@Observes Tick tick) {

    // update the UI with the new data
  }
}

使用 Errai 的其他好处是在服务器和客户端上都有开箱即用的 CDI，另一件很好的事情是使用幕后的网络套接字，如果它受支持，否则回退到其他解决方案。

无论您选择什么，它都应该适合您现有的基础架构和客户端 UI 框架。

Answer 2

每 30 秒或根据要求检查来自服务器的更新。

window.setInterval(function(){
  /// call your function here
 //Make AJAX call
 //Update Respective HTML Contact i,e, DIV

}, 30000);

Answer 3

Comet 也称为Reverse Ajax，是一种 Web 应用程序模型，其中长期持有的 HTTP 请求允许 Web 服务器将数据推送到浏览器，而无需浏览器显式请求。

Comet（又名长寿命 http，服务器推送） 允许服务器开始非常缓慢地响应浏览器的信息请求，并按照服务器规定的时间表继续响应。有关彗星的更多信息，请参阅以下内容：

• Alex Russell 的original post coining the term

• Wikipedia article on Comet

• Comet Daily，定期发布有关该主题的博客

DWR 是一个 Java 库，它使服务器上的 Java 和浏览器中的 JavaScript 能够尽可能简单地交互和调用。 借助 Reverse Ajax，DWR 允许在服务器上运行的 Java 代码使用客户端 API 将更新发布到任意组浏览器。这允许交互两种方式 - 浏览器调用服务器和服务器调用浏览器。 DWR 支持 Comet、Polling 和 Piggyback（通过正常请求发送数据）作为发布到浏览器的方式。

DWR 提供与 Spring、Struts、Guice、Hibernate 等的集成。 你可以从here阅读更多内容。

其他 Comet 和 Reverse AJAX 框架：

• Grizzly Comet API
• Atmosphere
• AJAX push with ICEfaces
• 使用 Servlet 3.0 的异步 Servlet

Answer 4

使用Node JS 和socket.io

该技术根据客户端使用的浏览器选择最佳的传输方式。

对于最新的浏览器，它使用 Web Sockets，而对于其他浏览器，它会优雅地降级为 Flash Socket 或 Long Pooling。 See more here

您需要做的是使用这些技术设置服务器。服务器将在特定端口上运行。所有客户端都将监听该端口，服务器将能够通过该端口将数据推送到客户端。

Answer 5

mqtt可用于服务器推送和消息广播。

http://mqtt.org/有更多详细信息。

=======================================

更新日期：2013 年 7 月 11 日

Mqtt 是一个发布/订阅，极其简单和轻量级的消息传递协议。如果服务器是发布者，客户端浏览器订阅服务器发布的主题，那么服务器可以直接向客户端推送消息。

一些有用的资源：

Mosquitto 是一个开源的 mqtt 服务器。易于安装和配置。

mqtt-client 是经过验证的强大的 java mqtt 客户端。

Answer 6

但是在 session.save(user) 之后 aftersave 方法没有被触发。

• @PostPersist 是一个 JPA 回调。
• session.save() 是一种非 JPA 的休眠专有方法。 JPA 使用entityManager.persist()。
• 您正在使用不兼容的功能