消息机制中生产者生产消息后消费者怎么就马上知道然后去消费的 ?
收起
你说的是消息队列吗?比如rabbtimq或rocketmq这种消息服务,一般来说,整个系统的关系是这样的,生产者->消息服务->消费者。它们之间都是socket长连接, 当生产者产生消息之后,会将消息发送到消息服务,这个消息会指定订阅的topic,消息服务会自动检测是否有消费者订阅了此topic,如果有订阅此topic的消费者, 消息服务就会主动把消息推送给消息费者,这样消费者就能立刻消费消息了。而rocketmq提供了两种方式,一个是推,一个是拉,拉取消息由消费者自己控制, 比如定时拉取。
报告相同问题?