最近项目需要把 mysql 里的数据读出来,序列化成 json,然后发给 rabbitmq,但是数据量庞大,导致 json 的 size 超过 90000,然后发现数据直接变成了乱码。后来发现就是因为数据量过大导致了,通过批量发送解决了问题。
def send_rabbitmq value
conn = Bunny.new(:host => "xxx.xxx.xxx.xxx", :vhost => "/", :user => "abc", :password =>"123")
conn.start
ch = conn.create_channel
ch.basic_publish( value ,"exchange.x", "routing.key", :payload_encoding => "string")
sleep 1.0
end