使用Hazelcast通过队列回复请求

我的主要目标是

>“一对多”的沟通与有多少人的保证回复
>“一对一”沟通单向
>“一对一”沟通,在一定时间内回答

总而言之,由于以下原因,我今天放弃了这种方法：

>许多复杂的代码,包括执行程序服务,callables,runnables,InterruptedException,shutdown-handling,hazelcast transaction等
>当接收者的寿命比发送者短时,在“一对一”通信的情况下悬挂消息
>如果我在合适的时间杀死了某些集群成员,则会丢失消息
>所有集群成员必须能够反序列化消息,因为它可以存储在任何位置.因此,对于某些客户端和服务,消息不能“特定”.

我切换到一个更简单的方法：

>所有“服务”使用hazelcast集群成员UUID作为密钥在MultiMap(“服务注册表”)中注册自己.每个条目都包含一些元信息,如服务标识符,加载因子,启动时间,主机,pid等
>客户端选择该MultiMap中其中一个条目的UUID,并使用DistributedTask(分布式执行程序服务)为选择的特定集群成员调用服务,并可选择获取答复(及时)
>只有服务客户端和服务必须在其类路径中具有特定的DistributedTask实现,所有其他集群成员都不会受到打扰
>客户端可以很容易地在服务注册表中找出死的条目：如果他们看不到具有特定UUID的集群成员(hazelcastInstance.getCluster().getMembers()),则该服务可能意外死亡.然后,客户端可以选择“活动”条目,较少负载因子的条目,在幂等服务的情况下进行重试等

使用第二种方法(例如超时或取消任务),编程变得非常简单和强大,更不用说要维护的代码.

希望这可以帮助！