异常信息

  1. PHP Fatal error:  Uncaught Swoole\Error: Socket#37 has already been bound to another coroutine#19895, reading of the same socket in coroutine#19896 at the same time is not allowed in /www/wwwroot/default/vendor/xxx.php:34
  2. Stack trace:
  3. xxxxxxxxxx

问题分析

从日志看像是同一个Socket链接不能同时存在于不同的协程里面,也就是不能夸协程使用mysql,redis同一条连接对象。

问题处理

知道问题就好处理了可以使用swoole channel 实现一个连接池如下：

Channel

  1. private static ?Channel $_dynamic_pool         = null; // 动态连接池
  2. private static array    $_static_pool          = []; // 静态连接池
  3. private static int      $_dynamic_pool_min_num = 50; // 动态连接池最大数量
  4. private string          $_static_pool_name; // 静态连接池名称
  6. public static function redisUtils($name = "")
  7. {
  8.         if ($name) {
  9.             self::$_static_pool[$name] = self::$_static_pool[$name] ?? new self();
  10.             $redisUtils                = self::$_static_pool[$name];
  11.         } else {
  12.             if (self::$_dynamic_pool === null) {
  13.                 self::$_dynamic_pool = new Channel(self::$_dynamic_pool_min_num);
  14.             }
  16.             if (self::$_dynamic_pool->isEmpty()) {
  17.                 for ($i = 1; $i <= self::$_dynamic_pool_min_num; $i++) {
  18.                     if (!self::$_dynamic_pool->isFull()) {
  19.                         self::$_dynamic_pool->push(new self());
  20.                     }
  21.                 }
  22.             }
  24.             if (!self::$_dynamic_pool->isEmpty()) {
  25.                 $redisUtils = self::$_dynamic_pool->pop();
  26.             } else {
  27.                 $redisUtils = new self();
  28.             }
  29.         }
  30.         $redisUtils->_static_pool_name = $name;
  31.         return $redisUtils;
  32. }
  34. // 静态连接池使用
  35. xxx::redisUtils("name")->get("xxxx");
  36. xxx::redisUtils("name")->set("xxxx");
  38. // 动态连接池使用
  39. xxx::redisUtils->get("xxxx");
  40. go(function(){
  41.     xxx::redisUtils->set("xxxx");
  42. })
  44. xxx::redisUtils->get("xxxx");
  45. go(function(){
  46.     xxx::redisUtils->set("xxxx");
  47. })

也可以使用swoole自带的相关mysql,redis连接池处理如下：

RedisPool

  1. <?php
  2. declare(strict_types=1);
  4. use Swoole\Coroutine;
  5. use Swoole\Database\RedisConfig;
  6. use Swoole\Database\RedisPool;
  7. use Swoole\Runtime;
  9. const N = 1024;
  11. Runtime::enableCoroutine();
  12. $s = microtime(true);
  13. Coroutine\run(function () {
  14.     $pool = new RedisPool((new RedisConfig)
  15.         ->withHost('127.0.0.1')
  16.         ->withPort(6379)
  17.         ->withAuth('')
  18.         ->withDbIndex(0)
  19.         ->withTimeout(1)
  20.     );
  21.     for ($n = N; $n--;) {
  22.         Coroutine::create(function () use ($pool) {
  23.             $redis = $pool->get();
  24.             $result = $redis->set('foo', 'bar');
  25.             if (!$result) {
  26.                 throw new RuntimeException('Set failed');
  27.             }
  28.             $result = $redis->get('foo');
  29.             if ($result !== 'bar') {
  30.                 throw new RuntimeException('Get failed');
  31.             }
  32.             $pool->put($redis);
  33.         });
  34.     }
  35. });
  36. $s = microtime(true) - $s;
  37. echo 'Use ' . $s . 's for ' . (N * 2) . ' queries' . PHP_EOL;

MysqliPool

  1. <?php
  2. declare(strict_types=1);
  4. use Swoole\Coroutine;
  5. use Swoole\Database\MysqliConfig;
  6. use Swoole\Database\MysqliPool;
  7. use Swoole\Runtime;
  9. const N = 1024;
  11. Runtime::enableCoroutine();
  12. $s = microtime(true);
  13. Coroutine\run(function () {
  14.     $pool = new MysqliPool((new MysqliConfig)
  15.         ->withHost('127.0.0.1')
  16.         ->withPort(3306)
  17.         // ->withUnixSocket('/tmp/mysql.sock')
  18.         ->withDbName('test')
  19.         ->withCharset('utf8mb4')
  20.         ->withUsername('root')
  21.         ->withPassword('root')
  22.     );
  23.     for ($n = N; $n--;) {
  24.         Coroutine::create(function () use ($pool) {
  25.             $mysqli = $pool->get();
  26.             $statement = $mysqli->prepare('SELECT ? + ?');
  27.             if (!$statement) {
  28.                 throw new RuntimeException('Prepare failed');
  29.             }
  30.             $a = mt_rand(1, 100);
  31.             $b = mt_rand(1, 100);
  32.             if (!$statement->bind_param('dd', $a, $b)) {
  33.                 throw new RuntimeException('Bind param failed');
  34.             }
  35.             if (!$statement->execute()) {
  36.                 throw new RuntimeException('Execute failed');
  37.             }
  38.             if (!$statement->bind_result($result)) {
  39.                 throw new RuntimeException('Bind result failed');
  40.             }
  41.             if (!$statement->fetch()) {
  42.                 throw new RuntimeException('Fetch failed');
  43.             }
  44.             if ($a + $b !== (int)$result) {
  45.                 throw new RuntimeException('Bad result');
  46.             }
  47.             while ($statement->fetch()) {
  48.                 continue;
  49.             }
  50.             $pool->put($mysqli);
  51.         });
  52.     }
  53. });
  54. $s = microtime(true) - $s;
  55. echo 'Use ' . $s . 's for ' . N . ' queries' . PHP_EOL;

总结

到此 PHP Fatal error: Uncaught Swoole\Error: Socket#37 has already been bound to another coroutine#19895, reading of the same socket in coroutine#19896 at the same time is not allowed in /www/wwwroot/default/vendor/xxx.php:34 类似的相关异常已经完美解决有更多不同的处理方式或者疑问可以评论回复。。。