2

使用安装了官方 docker 映像的 rabbit mq，我的工作人员在一段时间后（大约 40 秒）失败，出现异常 Bunny::NoFinalOctetError。

我的工人代码是：

require 'bunny'
require 'securerandom'

#TODO set host as parameter
rabbit_conn = Bunny.new
rabbit_conn.start

ch   = rabbit_conn.create_channel
q    = ch.queue("task", :durable => true)
ch.prefetch(1)

begin
  q.subscribe(:manual_ack => true, :block => true) do |delivery_info, properties, body|
        pp body 
    ch.ack(delivery_info.delivery_tag)
  end
rescue Interrupt => _
  rabbit_conn.close
end

我通过以下代码发送数据：

require "bunny"

conn = Bunny.new
conn.start

ch   = conn.create_channel
q    = ch.queue("task", :durable => true)

[
    'titi',
    'toto',
    'tata'
].each do |d|
    q.publish(d, :persistent => true)
end

sleep 1.0
conn.close

在 40 多岁之后，我的工人得到了以下输出

"titi"
"toto"
"tata"
E, [2017-10-18T15:56:55.938661 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>: Exception in the reader loop: Bunny::NoFinalOctetError: Frame doesn't end with � as it must, which means the size is miscalculated.
E, [2017-10-18T15:56:55.938890 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>: Backtrace: 
E, [2017-10-18T15:56:55.939037 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>:     /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/transport.rb:255:in `read_next_frame'
E, [2017-10-18T15:56:55.939114 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>:     /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/reader_loop.rb:68:in `run_once'
E, [2017-10-18T15:56:55.939175 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>:     /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/reader_loop.rb:35:in `block in run_loop'
E, [2017-10-18T15:56:55.939233 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>:     /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/reader_loop.rb:32:in `loop'
E, [2017-10-18T15:56:55.939288 #28583] ERROR -- #<Bunny::Session:0x56182de41e48 guest@127.0.0.1:5672, vhost=/, addresses=[127.0.0.1:5672]>:     /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/reader_loop.rb:32:in `run_loop'
Traceback (most recent call last):
        5: from worker2.rb:21:in `<main>'
        4: from /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/queue.rb:196:in `subscribe'
        3: from /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/consumer_work_pool.rb:77:in `join'
        2: from /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/consumer_work_pool.rb:77:in `each'
        1: from /home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/consumer_work_pool.rb:77:in `block in join'
/home/gg/.rvm/gems/ruby-head/gems/bunny-2.7.1/lib/bunny/consumer_work_pool.rb:77:in `join': caught an unexpected exception in the network loop: Frame doesn't end with � as it must, which means the size is miscalculated. (Bunny::NetworkFailure)

关于网络的更新

我嗅探了网络，因为它似乎是一个格式错误的网络数据包。实际上，错误是在收到特定数据包后触发的。

下面whireshark抓包，收到299包的时候报错。 在此处输入图像描述

但是我不知道这个数据包是什么，也不知道为什么兔子不处理它。

更新 Github 票

我在这里开了一张票

4

1 回答 1

0

原来是数据包解析的问题。

这个bug可以跟着她

于 2017-10-20T09:31:14.450 回答