hyperf 如何對AMQP消息進行手動消費?
- 2022 年 1 月 10 日
- 筆記
转发自白狼栈: 查看原文 在使用 hyperf 官方自带的 AMQP 队列时你会发现,不需要我们再额外启动进程对消息进行消费。这是因为默认情况下,使用 @Consumer 注解时,hyperf 会为我们自动创建子进程启动消费者,并且会在子进程异常退出后,重新拉起。 来看一个简单的例子。 1、创建pr …
Continue Reading转发自白狼栈: 查看原文 在使用 hyperf 官方自带的 AMQP 队列时你会发现,不需要我们再额外启动进程对消息进行消费。这是因为默认情况下,使用 @Consumer 注解时,hyperf 会为我们自动创建子进程启动消费者,并且会在子进程异常退出后,重新拉起。 来看一个简单的例子。 1、创建pr …
Continue Reading阅读目录 构建服务消费者 安装json rpc依赖 安装JSON RPC客户端 server配置 编写业务代码 编写服务消费者类 consumer配置 配置 UserServiceInterface 编写UserController postman测试 自动配置服务消费者 配置优化 统一结果处理 我 …
Continue Reading