问题描述
背景
我有一个包含许多机器的分布式系统。我有两种类型的应用程序-生产者和消费者。更具体地说-一个生产者和多个消费者。每个“消费者机器”都有多个消费者。
系统中的所有消息都将进入同一队列。消息看起来像这样:
{
"Id": "Thisismyid","CacheId": "CacheID"
...
}
我的使用者正在应用缓存策略,以便更快地处理队列消息。使用者下载该消息后,将检查CacheId
之前是否已被缓存。如果是,请继续。如果没有,请缓存并继续。
同一台计算机上的所有使用者都共享同一个缓存存储库。
问题
当我有1个使用者时,此结构为“最佳”。既然如此,同一台机器会缓存这些项目并多次使用。
随着使用者数量的增加-缓存的效率下降。因为它更有可能 将会由尚未准备好使用缓存的节点下载一项。
问题
如何使用RabbitMQ将具有相同CacheId
的消息“路由”为同一用户\机器处理以提高效率?就RabbitMQ资源而言,“成本”是多少?
解决方法
您也许可以通过主题交流来做到这一点:https://www.rabbitmq.com/tutorials/tutorial-five-dotnet.html
但是如果您有很多useEffect(() => {
async function initialFetch() {
const userList = await fetch('GET',GET_ALL_USERS)
setUserList(userList)
const roleList = await fetch('GET',GET_ALL_ROLES)
setRoleList(roleList)
}
if (!props.userList.status) {
initialFetch()
} else {
setUserList(props.userList)
setRoleList(props.roleList)
}
},[]);
,这将很快变得很复杂。
但是我会使用集中式缓存。可能是Redis:https://redis.io/