消息机制中生产者生产消息后消费者怎么就马上知道然后去消费的 ?

消息机制中生产者生产消息后消费者怎么就马上知道然后去消费的 ?

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

生产者是一个死循环,它每次生产完一个商品,就产生一个信号量,并且等待。
信号量被设置以前,生产者被阻塞,操作系统不会调度它执行,什么时候执行呢。
当消费者设置了信号量之后。