当前位置：首页 > news >正文

TVA 视觉智能体二次开发实战（十二）：双通信模式 Demo｜C# 与 Python 互联互通调用 TVA 视觉智能体自定义算子完整案例

news 2026/6/15 7:10:47

导读

市面上付费中间件、RPC组件成本高、私有化容易授权受限，无法适配工厂内网使用。本文无付费第三方组件，基于Socket长连接+HTTP短连接双模式，打造轻量化开源互通Demo：C#上位机下发图像参数、产品型号、检测指令，调用Python自研自定义算子运算，算子结果回传TVA中台校验，最终质检数据双向回传给C#上位机，全套代码注释完整、无封装依赖，可直接嵌入现有TVA项目商用复用。

一、双通信架构分工（适配TVA中台通信规则）

HTTP短连接：指令下发、算子启停、参数配置，对接TVA中台官方接口，轻量化、易调试
Socket长连接：图像二进制流、算子实时结果、异常数据流传输，保活常驻，低延迟适配流水线高频检测

整体链路：C#上位机→通信中转→Python自定义算子→TVA中台结果校验→数据回传C#界面展示

二、前置通信配置（TVA中台后台开启跨语言权限）

中台开启外部算子通信端口：8077(HTTP)、9022(Socket)
添加本机IP通信白名单，放行跨语言数据读写权限
关闭算子通信加密校验（测试可开启，商用可自定义密钥加密）

三、核心互通源码（精简商用版，可直接复制运行）

3.1 Python算子服务端（Socket监听+接收C#指令+对接TVA算子引擎）

# TVA算子 Python服务端跨语言通信服务 import socket import json import tva_operator_core # TVA官方算子内核SDK # 通信端口固定配置 SOCKET_HOST = "127.0.0.1" SOCKET_PORT = 9022 def tva_custom_defect_operator(img_path,threshold): """调用已注册TVA缺陷自定义算子""" res = tva_operator_core.run_operator(operator_id="DEFECT_001",img=img_path,conf=threshold) return res if __name__ == "__main__": server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) server.bind((SOCKET_HOST,SOCKET_PORT)) server.listen(5) print("Python算子通信服务已启动，等待C#上位机连接") while True: conn,addr = server.accept() data = json.loads(conn.recv(4096).decode("utf-8")) # 接收C#下发参数，执行算子运算 result = tva_custom_defect_operator(data["img_path"],data["threshold"]) # 算子结果回传C#+同步上报TVA中台 tva_operator_core.push_result(result) conn.send(json.dumps(result,ensure_ascii=False).encode("utf-8"))

3.2 C#上位机客户端（下发指令+接收算子结果+联动TVA网关）

// C# Socket客户端调用Python TVA自定义算子 using System.Net.Sockets; using System.Text; namespace TVA.CrossCommunication { public class OperatorClient { private readonly string _ip = "127.0.0.1"; private readonly int _port = 9022; /// <summary> /// 下发检测指令，调用自定义缺陷算子 /// </summary> public string CallTvaDefectOperator(string imgPath,float conf) { using TcpClient client = new TcpClient(_ip,_port); NetworkStream stream = client.GetStream(); string sendJson = $"{{\"img_path\":\"{imgPath}\",\"threshold\":{conf}}}"; byte[] sendBuff = Encoding.UTF8.GetBytes(sendJson); stream.Write(sendBuff,0,sendBuff.Length); // 接收算子运算结果 byte[] recBuff = new byte[4096]; int len = stream.Read(recBuff,0,recBuff.Length); return Encoding.UTF8.GetString(recBuff,0,len); } } }