專案從 Python 2 移轉到 Python 3 之後，

原本 IPC 機制裡使用到的 xmlrpc，

加上逾時 timeout 的機制不能用了，得重新在 Python 3 上實作…

 

上網找了一下，也有人在問 ServerProxy 為什麼不提供 timoeut 參數，

不過大大們的意見是這件事可以交給 Transport 來做，

不需要加在 ServerProxy 上面～

 

把大大們的範例碼拿來改一下，看起來應該是可以動。

先來做一個實驗的環境～

 

首先用 nc 跑一個 TCP server 聽在 port 19999，

假裝是一個不會回應的 xmlrpc server：

# nc -l -p 19999

 

接著，來看一下我們的 xmlrpc client 要怎麼寫吧～

我寫了一個  IPCClient 的類別，

裡面主要就是使用  xmlrpc.client.ServerProxy 來發出 XML RPC 的連線。

而逾期 timeout 的部分，則是建立一個  xmlrpc.client.Transport 物件，

並預先將其內部的  http.client.HTTPConnection 設定 timeout，

然後讓 xmlrpc.client.ServerProxy 使用這個 xmlrpc.client.Transport 物件，

這樣就可以在發出連線時，有逾時 timeout 的效果了：

import xmlrpc.client


class IPCClient:
    def __init__(self, port, server="127.0.0.1", timeout=5):
        # Prepare a transport with timeout
        ipc_host = "%s:%d" % (server, port)
        transport = xmlrpc.client.Transport()
        conn = transport.make_connection(ipc_host)
        conn.timeout = timeout

        self._proxy = xmlrpc.client.ServerProxy('http://%s' % (ipc_host), transport=transport, allow_none=True)

    def call(self, func_name, *func_params):
        # Call the function with given parameters
        return getattr(self._proxy, func_name)(*func_params)


if __name__ == "__main__":
    ipc_client = IPCClient(19999, timeout=3)
    print(ipc_client.call("debug"))

 

試著執行上面的程式，確實在 3 秒就會停止連線：

# time python3 ipcclient.py

Traceback (most recent call last):
  File "ipcclient.py", line 21, in <module>
    print(ipc_client.call("debug"))
  File "ipcclient.py", line 16, in call
    result = getattr(self._proxy, func_name)(*func_params)
  File "/usr/lib64/python3.6/xmlrpc/client.py", line 1112, in __call__
    return self.__send(self.__name, args)
  File "/usr/lib64/python3.6/xmlrpc/client.py", line 1452, in __request
    verbose=self.__verbose
  File "/usr/lib64/python3.6/xmlrpc/client.py", line 1154, in request
    return self.single_request(host, handler, request_body, verbose)
  File "/usr/lib64/python3.6/xmlrpc/client.py", line 1167, in single_request
    resp = http_conn.getresponse()
  File "/usr/lib64/python3.6/http/client.py", line 1346, in getresponse
    response.begin()
  File "/usr/lib64/python3.6/http/client.py", line 307, in begin
    version, status, reason = self._read_status()
  File "/usr/lib64/python3.6/http/client.py", line 268, in _read_status
    line = str(self.fp.readline(_MAXLINE + 1), "iso-8859-1")
  File "/usr/lib64/python3.6/socket.py", line 586, in readinto
    return self._sock.recv_into(b)
socket.timeout: timed out

real	0m3.368s
user	0m0.323s
sys	0m0.042s

 

在外部用 time 指令檢查執行時間，比較不準確，

因為會把程式啟動以及結束的時間都計入，

不過大概還是可以看出程式有依照 timeout 的時間在運作囉～

 

參考資料：問題 14134: xmlrpc.client.ServerProxy needs timeout parameter