账号密码登录
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
找回密码返回
邮箱找回 手机找回
注册账号返回
其他登录方式
分享
  • 收藏
    X
    nsq的hanlder任务执行时间一长会报IO error错误(大概两分钟左右)
    80
    0

    小弟正在开发go语言基于nsq的异步任务。但是现在发现,只要任务时间一长,客户端就会报错,报错信息如下:
    2019/08/28 09:21:59 ERR 2 [free/alfx] (127.0.0.1:4150) IO error - write tcp 127.0.0.1:49703->127.0.0.1:4150: write: broken pipe
    2019/08/28 09:21:59 ERR 2 [free/alfx] (127.0.0.1:4150) error sending RDY 1 - write tcp 127.0.0.1:49703->127.0.0.1:4150: write: broken pipe
    2019/08/28 09:21:59 WRN 2 [free/alfx] (127.0.0.1:4150) delaying close, 1 outstanding messages
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) readLoop exiting
    2019/08/28 09:21:59 ERR 2 [free/alfx] (127.0.0.1:4150) IO error - write tcp 127.0.0.1:49703->127.0.0.1:4150: write: broken pipe
    2019/08/28 09:21:59 ERR 2 [free/alfx] (127.0.0.1:4150) error sending command FIN 0bf6a0f2ad358000 - write tcp 127.0.0.1:49703->127.0.0.1:4150: write: broken pipe
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) beginning close
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) breaking out of writeLoop
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) writeLoop exiting
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) finished draining, cleanup exiting
    2019/08/28 09:21:59 INF 2 [free/alfx] (127.0.0.1:4150) clean close complete

    目测是链接超时,回写消费状态失败了,但是小弟调了好多参数,也没能避免这个报错。烦请各位大大指点,非常感谢

    2
    打赏
    收藏
    点击回答
    您的回答被采纳后将获得:提问者悬赏的 10 元积分
        全部回答
    • 0
    • Nsq的Hadoop作业执行时间过长,可能会报IO错误(大约两分钟左右)。这可能是因为Nsq的内存使用过高,或者是Nsq的磁盘读写速度较慢。你可以尝试以下步骤来解决这个问题:

      1. 优化Hadoop作业:如果你的Hadoop作业的数据量过大,那么可能会导致Nsq的内存使用过高。你可以尝试使用Nsq的压缩功能,将数据压缩到一个较小的文件中,以减少内存使用。

      2. 增加磁盘读写速度:你可以尝试增加磁盘读写速度。例如,你可以使用Nsq的缓存功能,将经常访问的数据存储在缓存中,以减少磁盘读写的时间。

      3. 优化Nsq的配置:你可以在Nsq的配置文件中,调整一些配置选项,例如增加Nsq的内存使用量,或者减少Nsq的磁盘读写速度。

      4. 升级硬件:如果上述方法都无法解决问题,那么你可能需要考虑升级你的硬件,例如增加更多的内存,或者使用更快的磁盘。

      请注意,上述方法都只是暂时的解决方案,如果问题持续存在,你可能需要考虑升级Nsq的硬件或者寻求专业的技术支持。

    更多回答
    扫一扫访问手机版
    • 回到顶部
    • 回到顶部