amqp.php 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4. * This file is part of Hyperf.
  5. *
  6. * @link https://www.hyperf.io
  7. * @document https://hyperf.wiki
  8. * @contact group@hyperf.io
  9. * @license https://github.com/hyperf/hyperf/blob/master/LICENSE
  10. */
  11. return [
  12. 'default' => [
  13. 'enable' => env('AMPQ_ENABLE', false),
  14. 'host' => env('RABBITMQ_HOST', 'localhost'),
  15. 'port' => (int) env('RABBITMQ_PORT', 5672),
  16. 'user' => env('RABBITMQ_USER', 'guest'),
  17. 'password' => env('RABBITMQ_PASSWORD', 'guest'),
  18. 'vhost' => env('RABBITMQ_VHOST', '/'),
  19. 'concurrent' => [
  20. 'limit' => 1,
  21. ],
  22. 'pool' => [
  23. // 同时开启的连接数
  24. // 因为新版本连接是支持多路复用的,所以可以用极少的连接数达到很高的并发
  25. 'connections' => (int)env('RABBITMQ_POOL_MAX_CONNECTION', 2),
  26. ],
  27. 'params' => [
  28. 'insist' => false,
  29. 'login_method' => 'AMQPLAIN',
  30. 'login_response' => null,
  31. 'locale' => 'en_US',
  32. 'connection_timeout' => 3.0,
  33. 'read_write_timeout' => 6.0,
  34. 'context' => null,
  35. 'keepalive' => false,
  36. 'heartbeat' => 3,
  37. 'channel_rpc_timeout' => 0.0,
  38. 'close_on_destruct' => false,
  39. // 多路复用中闲置 Channel 的最大值,超过这个数量后,会关闭多余的限制 Channel
  40. 'max_idle_channels' => 10,
  41. ],
  42. ],
  43. ];