当前位置：文江博客话题详情

Hazelcast 客户端流 API

发布于 2025-01-10 00:52:44 字数 116 浏览 1 评论 0原文

我正在使用 Hazelcast 多重贴图。如何根据我的密钥为 Hazelcast 多地图侦听器创建流 API。我需要在任何前端应用程序中使用该 API。 Hazelcast 地图中是否有任何更改需要反映到 API 中。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

软糯酥胸 2025-01-17 00:52:44

import logging

import hazelcast

logging.basicConfig(level=logging.INFO)

client = hazelcast.HazelcastClient()

multi_map = client.get_multi_map("test").blocking()


def on_entry_added(entry_event):
    print(entry_event)
    # Do something with the event.
    # Do not perform blocking operations here.
    # If you need to perform blocking operations
    # offload them to another thread.


multi_map.add_entry_listener(
    include_value=True,
    key="your key",
    added_func=on_entry_added,
)


for i in range(1000):
    multi_map.put("your key", i)

import logging

import hazelcast

logging.basicConfig(level=logging.INFO)

client = hazelcast.HazelcastClient()

multi_map = client.get_multi_map("test").blocking()


def on_entry_added(entry_event):
    print(entry_event)
    # Do something with the event.
    # Do not perform blocking operations here.
    # If you need to perform blocking operations
    # offload them to another thread.


multi_map.add_entry_listener(
    include_value=True,
    key="your key",
    added_func=on_entry_added,
)


for i in range(1000):
    multi_map.put("your key", i)

回复收藏 0 原文

~没有更多了~