Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

这个是不是还得继承 JobConsumer 来消费消息 #3

Closed
anhao opened this issue Oct 11, 2024 · 6 comments
Closed

这个是不是还得继承 JobConsumer 来消费消息 #3

anhao opened this issue Oct 11, 2024 · 6 comments

Comments

@anhao
Copy link

anhao commented Oct 11, 2024

我这边测试继承 Job 投递消息后并没有消费消息,只是把消息投递了

@huangdijia
Copy link
Contributor

是的,已经更新 readme

@anhao
Copy link
Author

anhao commented Oct 11, 2024

如果能实现自动将消费者注册的话就简单多了 ,就不用重复创建 Consumer ,直接创建 job,和Laravel一样

https://github.com/hyperf/hyperf/blob/master/src/amqp/src/ConsumerManager.php#L30

@huangdijia
Copy link
Contributor

本身也是基于 hyperf 的,受限于 amqp 本身的复杂配置(交换机、路由、队列、进程数等等),自定义配置会灵活些。

或者看你有没有什么想法,欢迎 PR

@anhao
Copy link
Author

anhao commented Oct 11, 2024

就是这种 https://github.com/anhao/components/tree/3.x/src/amqp-job

不过遇到一个问题,消费完消息后,相关的队列Process会自动重启

@anhao
Copy link
Author

anhao commented Oct 12, 2024

提交了一个PR , friendsofhyperf/components#720

@huangdijia
Copy link
Contributor

提交了一个PR , friendsofhyperf/components#720

我也刚提交了一个

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants