Simple模式
2022-03-16 / 2 min read
最简单常用的模式
创建的过程
首先我们要有一个rabbitmq的结构体,用于创建rabbitmq实例。
然后我们需要一个全局的连接url:
在里面我们解释了每一个参数意思。然后我们开始创建这个rabbitmq的实例:这里我们看到上面的结构体,我们可以看到,我们需要传入的参数是三个,
创建了实例过后我们还要进行连接和获取通道,这样我们就算连接成功了这个rabbitmq。
这里段代码里面我们看到了还有处理错误的代码,这是我们在工程中应该注意的问题。
然后为了方便这里我们写了一个构造函数:
生产者逻辑代码
对于生产者代码中,我们首先需要申请队列,因为我们的消息是发送到队列中的。这里需要注意里面的参数意思。
然后我们请求到了队列,然后我们就要讲这些消息放进队列里面去
消费者逻辑代码
首先还是一样的,我们首先需要申请队列,这里申请的步骤和上面一样,这里就不再展示,然后这里我们直接展示消费者的核心代码。
我们首先接收到消息
然后对消息进行处理