服務端程式碼 test_socket_consumer.py，先啟動服務端

from function_scheduling_distributed_framework import task_deco, BrokerEnum


@task_deco('10.0.126.147:5691', broker_kind=BrokerEnum.TCP)   #可以寫TCP， 也可以寫UDP那就是udp socket協議。
def f(x):
    print(x * 10)


if __name__ == '__main__':
    f.consume()
    #for i in range(10):
 

       # f.push(f'hello {i}')

客戶端程式碼，可以啟動多個客戶端指令碼。

import time
from test_socket_consumer import f

for i in range(1000000):
    time.sleep(1)
    # print(i)
    f.push(i)

這樣就完成了客戶端和服務端的互動了。不需要親自手動寫一大堆socket連線程式碼了,這樣如果大量開發tcp任務時候開發效率變快很多。