a.xxx{ |msg| function(msg)}
def function (msg)
price = msg.price
size = msg.size
status = msg.size
timestamp = msg.timestamp
end
现在是这样的,price/size/status/timestamp 每次内容只更新一个,然后保存到数据库 其他的变量值需要延用上次得到的值, 目前的解决方案是使用全局变量声明,但涉及到多个同时跑的时候就很捉襟见肘 一个初步的想法是将 def 直接写到{msg}这里,还有更优雅一点的方案么