udpsock:receive超时的问题

mcfeeboin

hi all，

最近我使用lua通过UDP协议和同一机器上的C程序做数据交换。然后遇到了udpsock:receive()无法接受到数据的问题。

我测试了很久，首先C程序应该没有问题，排查方式如下：

udpsock:send() 的数据C程序可以接到，并且打出log
同样的数据使用C代码或者python代码实现都可以正常接收到结果
同样的数据使用lua的socket模块（非ngx.sock）也可以接收到结果

我原本使用 ngx-1.2.7 + ngx_lua 0.8.4 有问题，然后升级到 ngx-1.4.3 + ngx_lua 0.9.0 问题依旧（因为某些原因无法直接使用openresty）

代码比较多，通讯函数的代码如下：

local function query (uids)                                                     
    msg = {cmd="query",data=""                                         
    msg = json.encode(msg);                                                     
        local sock, data = "" ""                                 
        sock:settimeout(1000)  -- 1 second timeout                              
        local ok, err = sock:setpeername("127.0.0.1", port)                 
        if not ok then                                                          
            return                                                              
        else                                                                    
            ok, err = sock:send(msg)                                            
            if ok then                                                          
                ngx.say("successfully connected to sandglass and send msg", msg)
                data, err = sock:receive()                                      
                if not data then                                                
                    ngx.say("failed to read a packet: ", data)                  
                        -- return                                               
                else                                                            
                    ngx.say("successfully read a packet: ", data)               
                end                                                             
            else                                                                
                ngx.say("failed to send msg to sandglass : ", err)              
            end                                                                 
            sock:close()                                                        
        end                                                                                                                                          
end                                                                             

curl 返回 failed to read a packet: nil

tcpdump 抓包是有返回了结果的

20:02:01.224347 IP (tos 0x0, ttl  64, id 20166, offset 0, flags [DF], proto: UDP (17), length: 72) 127.0.0.1.62012 > 127.0.0.1.13601: [udp sum ok] UDP, length 44
	0x0000:  4500 0048 4ec6 4000 4011 eddc 7f00 0001  E..HN.@.@.......
	0x0010:  7f00 0001 f23c 3521 0034 48c7 7b22 6461  .....<5!.4H.{"da
	0x0020:  7461 223a 7b22 6f69 6422 3a5b 312c 322c  ta":{"oid":[1,2,
	0x0030:  332c 342c 352c 365d 7d2c 2263 6d64 223a  3,4,5,6]},"cmd":
	0x0040:  2271 7565 7279 227d                      "query"}
20:02:01.224704 IP (tos 0x0, ttl  64, id 0, offset 0, flags [DF], proto: UDP (17), length: 191) 127.0.0.1.blackjack > 127.0.0.1.62012: UDP, length 163
	0x0000:  4500 00bf 0000 4000 4011 3c2c 7f00 0001  E.....@.@.<,....
	0x0010:  7f00 0001 0401 f23c 00ab a27e 5b7b 2275  .......<...~[{"u
	0x0020:  6964 223a 2231 222c 226f 6e6c 696e 6522  id":"1","online"
	0x0030:  3a66 616c 7365 7d2c 7b22 7569 6422 3a22  :false},{"uid":"
	0x0040:  3222 2c22 6f6e 6c69 6e65 223a 6661 6c73  2","online":fals
	0x0050:  657d                                     e}

ngx环境是

nginx version: nginx/1.4.3
built by gcc 4.1.2 20080704 (Red Hat 4.1.2-54)
TLS SNI support disabled
configure arguments: --prefix=/usr/local/nginx-1.4.3 --with-http_sub_module --with-http_stub_status_module --with-http_ssl_module --with-http_gzip_static_module --add-module=exp/echo-nginx-module/ --add-module=exp/lua-nginx-module/ --add-module=exp/ngx_devel_kit/ --add-module=exp/set-misc-nginx-module/ --add-module=exp/ngx_cache_purge/ --add-module=exp/nginx-push-stream-module

其中所有exp均为git最新的tag

使用luajit 2.0.2 编译

请各位帮忙看看，谢谢了

mcfeeboin

补充一个细节，我用tcpdump抓了lo的所有包发现，C程序回复的包不可达发送端口。

14:09:04.134470 IP (tos 0x0, ttl  64, id 7660, offset 0, flags [DF], proto: UDP (17), length: 72) 127.0.0.1.15275 > 127.0.0.1.13601: [udp sum ok] UDP, length 44
	0x0000:  4500 0048 1dec 4000 4011 1eb7 7f00 0001  E..H..@.@.......
	0x0010:  7f00 0001 3bab 3521 0034 ff58 7b22 6461  ....;.5!.4.X{"da
	0x0020:  7461 223a 7b22 6f69 6422 3a5b 312c 322c  ta":{"oid":[1,2,
	0x0030:  332c 342c 352c 365d 7d2c 2263 6d64 223a  3,4,5,6]},"cmd":
	0x0040:  2271 7565 7279 227d                      "query"}
14:09:04.134663 IP (tos 0x0, ttl  64, id 0, offset 0, flags [DF], proto: UDP (17), length: 191) 127.0.0.1.blackjack > 127.0.0.1.15275: UDP, length 163
	0x0000:  4500 00bf 0000 4000 4011 3c2c 7f00 0001  E.....@.@.<,....
	0x0010:  7f00 0001 0401 3bab 00ab 5910 5b7b 2275  ......;...Y.[{"u
	0x0020:  6964 223a 2231 222c 226f 6e6c 696e 6522  id":"1","online"
	0x0030:  3a66 616c 7365 7d2c 7b22 7569 6422 3a22  :false},{"uid":"
	0x0040:  3222 2c22 6f6e 6c69 6e65 223a 6661 6c73  2","online":fals
	0x0050:  657d                                     e}
14:09:04.134691 IP (tos 0xc0, ttl  64, id 56863, offset 0, flags [none], proto: ICMP (1), length: 219) 127.0.0.1 > 127.0.0.1: ICMP 127.0.0.1 udp port 15275 unreachable, length 199
	IP (tos 0x0, ttl  64, id 0, offset 0, flags [DF], proto: UDP (17), length: 191) 127.0.0.1.blackjack > 127.0.0.1.15275: UDP, length 163[|icmp]
	0x0000:  45c0 00db de1f 0000 4001 9d40 7f00 0001  E.......@..@....
	0x0010:  7f00 0001 0303 fbbb 0000 0000 4500 00bf  ............E...
	0x0020:  0000 4000 4011 3c2c 7f00 0001 7f00 0001  ..@.@.<,........
	0x0030:  0401 3bab 00ab 5910 5b7b 2275 6964 223a  ..;...Y.[{"uid":
	0x0040:  2231 222c 226f 6e6c 696e 6522 3a66 616c  "1","online":fal
	0x0050:  7365                                     se

mcfeeboin

已经有初步结论了。回头解决了贴方案。

agentzh

Hello!

2013/10/24 黄欢:
>       最近我使用lua通过UDP协议和同一机器上的C程序做数据交换。然后遇到了udpsock:receive()无法接受到数据的问题。
>

你需要提供一个最小化的完整示例（包括你使用的客户端和服务器端，以及复现问题所需的步骤），以便我能在我本地复现你看到的问题。这样可以节约许多沟通成本 :)

另外，值得一提的是，你的 Lua 代码中的错误处理值得改进。比如在出错时，你输出 err 返回值比输出已知为 nil 的 data 返回值要更有意义，比如

    local data, err = sock:receive()
    if not data then
        ngx.say("failed to read a packet: ", err)
    end

Regards,
-agentzh