如何解决RabbitMQ-将具有共同属性的消息发送给同一使用者
背景
我有一个包含许多机器的分布式系统。我有两种类型的应用程序-生产者和消费者。更具体地说-一个生产者和多个消费者。每个“消费者机器”都有多个消费者。
系统中的所有消息都将进入同一队列。消息看起来像这样：
{
"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/
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
