關於Redis-publish/subscribe

Posted on Edited on In Views: Disqus: Symbols count in article: 507 Reading time ≈ 1 mins.

關於Redis-publish/subscribe

這篇介紹Redis-publish/subscribe。

AppInit做subscribe

1
2
3
4
5
RedisSubscriberType.VALUES.stream().forEach(x -> {
	if (x.subscribe()) {
		LogUtils.system.info("init RedisSubscriberType " + x.name());
	}
});

使用publish更新資料

1
RedisSubscriberType.DataSync.publish(JSONUtils.toJsonString(updateData.get()));

publish

1
RedisManager.get().getTopic(channel).publish(data);

subscribe

1
2
3
RedisManager.get().getTopic(channel).addListener(String.class, (channel, message) -> {

});