redis 订阅报 Error while reading line from the server [tcp://120..:6379]

问答 / 17 / 7 / 创建于 2年前 / 更新于 2年前

1. 运行环境

Welcome to Alibaba Cloud Elastic Compute Service

1). 当前使用的 Laravel 版本？

Laravel Framework 8.83.27

2). 当前使用的 php/php-fpm 版本？

PHP 版本：
PHP 7.4.28 (cli)

php-fpm 版本：

3). 当前系统

CentOS Linux release 8.2.2004 (Core)

4). 业务环境

开发环境

5). 相关软件版本

redis_version:6.0.9

2. 问题描述？

执行订阅操作报 Error while reading line from the server. [tcp://120...**:6379]
代码如下

配置
config/database.php  
redis host passord 在 .env 文件已配置
   'redis' => [
       'client' => env('REDIS_CLIENT', 'predis'),
        'default' => [
            'url' => env('REDIS_URL'),
            'host' => env('REDIS_HOST', '120.0.0.1'),
            'password' => env('REDIS_PASSWORD', null),
            'port' => env('REDIS_PORT', 6379),
            'database' => 0,
            'read_write_timeout' => env('REDIS_RW_TIMEOUT', 30),  // 读写超时设定
    ]
   ]

routes\web.php
Route::get('/publish/{msg}', function ($msg) {
    \Illuminate\Support\Facades\Redis::publish('test-channel',$msg); // 发布消息
    return json_encode(['msg'=>$msg]);
});

Route::get('/subscribe', function () {
    \Illuminate\Support\Facades\Redis::subscribe(['test-channel'], function ($message) { // 订阅消息
        echo $message;
    });
});

发布OK

redis 订阅报 Error while reading line from the server

redis 订阅报 read error on connection to IP:PORT

redis 订阅报 Error while reading line from the server

订阅失败

redis 订阅报 read error on connection to IP:PORT

3. 您期望得到的结果？

期望订阅成功

4. 您实际得到的结果？

Predis\Connection\ConnectionException: Error while reading line from the server. [tcp://120.**.**.**:6379] in file /www/dana/php/blog/vendor/predis/predis/src/Connection/AbstractConnection.php on line 131

#0 /www/dana/php/blog/vendor/predis/predis/src/Connection/StreamConnection.php(286): Predis\Connection\AbstractConnection-&gt;onConnectionError()
#1 /www/dana/php/blog/vendor/predis/predis/src/PubSub/Consumer.php(116): Predis\Connection\StreamConnection-&gt;read()
#2 /www/dana/php/blog/vendor/predis/predis/src/PubSub/AbstractConsumer.php(171): Predis\PubSub\Consumer-&gt;getValue()
#3 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Redis/Connections/PredisConnection.php(45): Predis\PubSub\AbstractConsumer-&gt;current()
#4 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Redis/Connections/Connection.php(90): Illuminate\Redis\Connections\PredisConnection-&gt;createSubscription()
#5 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Redis/RedisManager.php(277): Illuminate\Redis\Connections\Connection-&gt;subscribe()
#6 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Support/Facades/Facade.php(261): Illuminate\Redis\RedisManager-&gt;__call()
#7 /www/dana/php/blog/routes/web.php(46): Illuminate\Support\Facades\Facade::__callStatic()
#8 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Route.php(238): Illuminate\Routing\RouteFileRegistrar-&gt;{closure}()
#9 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Route.php(208): Illuminate\Routing\Route-&gt;runCallable()
#10 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Router.php(721): Illuminate\Routing\Route-&gt;run()
#11 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(128): Illuminate\Routing\Router-&gt;Illuminate\Routing\{closure}()
#12 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Middleware/SubstituteBindings.php(50): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#13 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Routing\Middleware\SubstituteBindings-&gt;handle()
#14 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/VerifyCsrfToken.php(78): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#15 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Foundation\Http\Middleware\VerifyCsrfToken-&gt;handle()
#16 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/View/Middleware/ShareErrorsFromSession.php(49): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#17 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\View\Middleware\ShareErrorsFromSession-&gt;handle()
#18 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Session/Middleware/StartSession.php(121): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#19 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Session/Middleware/StartSession.php(64): Illuminate\Session\Middleware\StartSession-&gt;handleStatefulRequest()
#20 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Session\Middleware\StartSession-&gt;handle()
#21 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Cookie/Middleware/AddQueuedCookiesToResponse.php(37): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#22 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Cookie\Middleware\AddQueuedCookiesToResponse-&gt;handle()
#23 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Cookie/Middleware/EncryptCookies.php(67): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#24 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Cookie\Middleware\EncryptCookies-&gt;handle()
#25 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(103): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#26 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Router.php(723): Illuminate\Pipeline\Pipeline-&gt;then()
#27 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Router.php(698): Illuminate\Routing\Router-&gt;runRouteWithinStack()
#28 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Router.php(662): Illuminate\Routing\Router-&gt;runRoute()
#29 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Routing/Router.php(651): Illuminate\Routing\Router-&gt;dispatchToRoute()
#30 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Kernel.php(167): Illuminate\Routing\Router-&gt;dispatch()
#31 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(128): Illuminate\Foundation\Http\Kernel-&gt;Illuminate\Foundation\Http\{closure}()
#32 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/TransformsRequest.php(21): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#33 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/ConvertEmptyStringsToNull.php(31): Illuminate\Foundation\Http\Middleware\TransformsRequest-&gt;handle()
#34 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull-&gt;handle()
#35 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/TransformsRequest.php(21): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#36 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/TrimStrings.php(40): Illuminate\Foundation\Http\Middleware\TransformsRequest-&gt;handle()
#37 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Foundation\Http\Middleware\TrimStrings-&gt;handle()
#38 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/ValidatePostSize.php(27): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#39 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Foundation\Http\Middleware\ValidatePostSize-&gt;handle()
#40 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Middleware/PreventRequestsDuringMaintenance.php(86): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#41 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Foundation\Http\Middleware\PreventRequestsDuringMaintenance-&gt;handle()
#42 /www/dana/php/blog/vendor/fruitcake/laravel-cors/src/HandleCors.php(38): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#43 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Fruitcake\Cors\HandleCors-&gt;handle()
#44 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Http/Middleware/TrustProxies.php(39): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#45 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(167): Illuminate\Http\Middleware\TrustProxies-&gt;handle()
#46 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Pipeline/Pipeline.php(103): Illuminate\Pipeline\Pipeline-&gt;Illuminate\Pipeline\{closure}()
#47 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Kernel.php(142): Illuminate\Pipeline\Pipeline-&gt;then()
#48 /www/dana/php/blog/vendor/laravel/framework/src/Illuminate/Foundation/Http/Kernel.php(111): Illuminate\Foundation\Http\Kernel-&gt;sendRequestThroughRouter()
#49 /www/dana/php/blog/public/index.php(52): Illuminate\Foundation\Http\Kernel-&gt;handle()
#50 {main}

redis 订阅

课程读者 15 声望

暂无个人描述~

《L02 从零构建论坛系统》

以构建论坛项目 LaraBBS 为线索，展开对 Laravel 框架的全面学习。应用程序架构思路贴近 Laravel 框架的设计哲学。

《G01 Go 实战入门》

从零开始带你一步步开发一个 Go 博客项目，让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。

推荐文章：

更多推荐...

Redis 实用小技巧——记一次 Redis 「大扫除」行动 12 / 6 |

手摸手带你使用 docker-compose 编排一个开发环境 21 / 15 |

Tiny RDM - 您的极简Redis数据管理利器！高效、易用、快速部署。立即体验！🚀! 欢迎各位来尝鲜. 13 / 23 |

Redis 实用小技巧——浅谈 Redis 使用规范 11 / 8 |

Redis 实用小技巧—— bitmap 应用之「位排序」 13 / 5 |

Redis 实用小技巧—— bitmap 应用之「签到统计」 18 / 14 |

快乐的皮拉夫

版主 1.9k 声望

最佳答案

你这个测试方法不对，subscribe 操作是一个阻塞操作，放到路由里测试的话，相当于让 http 请求一直处于等待的状态，超过默认连接时长或 http 请求时长的话，就会报错了。

当然，如果你请求完以后，在超时之前往 channel 里 publish 一条消息，这样也能正常打印，正常响应。

你这个应该放到 cli 模式下作测试，这样就不会有超时一说了。

已经亲测，放心使用。

2年前评论

dana （楼主）

错误信息还是一样的
Laravel

<?php

namespace App\Console\Commands;

use App\Models\Orders;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Redis;
use function App\Extend\str_after;
use function App\Extend\str_before;

class ordersExpireListen extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'order:expire';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '监听订单创建，在30分钟后如果没付款取消订单';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {

        Redis::subscribe(['test-channel'], function($message){
            echo $message;
        });
    }
}

快乐的皮拉夫（作者）

@dana 你在 database.php 中增加了读写超时设置 'read_write_timeout' => env('REDIS_RW_TIMEOUT', 30)，注释掉再试试。

讨论数量: 7

快乐的皮拉夫

版主 1.9k 声望

你这个测试方法不对，subscribe 操作是一个阻塞操作，放到路由里测试的话，相当于让 http 请求一直处于等待的状态，超过默认连接时长或 http 请求时长的话，就会报错了。

当然，如果你请求完以后，在超时之前往 channel 里 publish 一条消息，这样也能正常打印，正常响应。

你这个应该放到 cli 模式下作测试，这样就不会有超时一说了。

已经亲测，放心使用。

2年前评论

dana （楼主）

错误信息还是一样的
Laravel

<?php

namespace App\Console\Commands;

use App\Models\Orders;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Redis;
use function App\Extend\str_after;
use function App\Extend\str_before;

class ordersExpireListen extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'order:expire';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '监听订单创建，在30分钟后如果没付款取消订单';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {

        Redis::subscribe(['test-channel'], function($message){
            echo $message;
        });
    }
}

快乐的皮拉夫（作者）

@dana 你在 database.php 中增加了读写超时设置 'read_write_timeout' => env('REDIS_RW_TIMEOUT', 30)，注释掉再试试。

sanders

课程读者 648 声望 / 程序员鼓励师 @ KDD

redis 是不是用的阿里云集群版？集群版貌似限制了不能使用 sub/pub 命令。单机版貌似不影响。

2年前评论

dana （楼主）

个人使用的应该不是集群版吧

dana

课程读者 15 声望

我大概知道为啥报错了，因为订阅后长时间没有信息。然后报错了

[root@iZwz91u64hvs1r58q5s9fjZ blog]# php artisan order:expire  // 启动订阅
    ddhaoxiaohaoxiaoziyaya  // 接收信息   
   Predis\Connection\ConnectionException   // 长时间没有消息 redis 断开 然后报错

  Error while reading line from the server. [tcp://120.**.**.**:6379]

  at vendor/predis/predis/src/Connection/AbstractConnection.php:131
    127▕      */
    128▕     protected function onConnectionError($message, $code = 0)
    129▕     {
    130▕         CommunicationException::handle(
  ➜ 131▕             new ConnectionException($this, "$message [{$this->getParameters()}]", $code)
    132▕         );
    133▕     }

2年前评论

快乐的皮拉夫

是的，使用 http 接口订阅和 cli 的方式订阅都会受限于读写操作的超时时间设置，用订阅的话需要把这个限制放开。手动调整超时时间也是可以测试出来的。

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助