发表新帖

使用swoole官方的连接池RedisPool，依然还是报了redis实例混用的错误

### 问题描述
代码第14行报错：
PHP Fatal error:  Uncaught Swoole\Error: Socket#9 has already been bound to another coroutine#4229695, reading of the same socket in coroutine#4229696 at the same time is not allowed.
意思是在不同的协程里使用了同一个redis链接，可我使用的就是swoole官方提供的协程高级-redis连接池，怎么还会报这么错误？是我代码写错了么？

### Swoole版本，PHP版本，以及操作系统版本信息
php 7.3.21
Swoole 4.6.4

### 相关代码
```php
	#Redis连接池
	$redisPool = new RedisPool((new RedisConfig)
			->withHost($env['CACHE']['HOST'])
			->withPort((int)$env['CACHE']['PORT'])
			->withAuth('')
			->withDbIndex(0)
			->withTimeout(1)
			);
	#监听应用中心-消费券状态
	Swoole\Timer::tick(200, function($timer_id) use ($chan,$pdoPool,$redisPool,$env){
		$cname = $env['CACHE']['PREFIX'].'marketing-coupon-state';
		try {
			$redis = $redisPool->get();
			$dataJson = (string)$redis->rPop($cname);
			$dataArray = @json_decode($dataJson, true);
			if(!empty($dataArray) && is_array($dataArray)){
				if (time() >= $dataArray['etime'] && $dataArray['state'] < 3){
					$state = 3; #已结束
					$chan->push(['type'=>'marketing-coupon-state','data'=>['id'=>$dataArray['id'],'state'=>$state]]);
				}elseif (time() > $dataArray['stime'] && time() < $dataArray['etime'] && $dataArray['state'] < 2){
					$state = 2; #进行中
					$chan->push(['type'=>'marketing-coupon-state','data'=>['id'=>$dataArray['id'],'state'=>$state]]);
				}else {
					#不满足任意条件，重新写入队列
					$redis->lpush($cname, $dataJson);
				}
			}
		} catch (\Exception $e) {
			abelog($e);
		} catch (\Error $e) {
			abelog($e);
		}
		if(!empty($redis))$redisPool->put($redis);
	});
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
帮忙看一下到底是什么原因

发布于3年前 · 42 次浏览 · 来自提问