TCP/UDP客户端
net
组件:用于将消息发送到指定网络协议的服务器。支持多种网络协议,包括TCP、UDP、IPv4、IPv6、Unix Socket等。该组件仅支持发送数据,不支持读取响应数据。
支持的协议类型包括:
- tcp: TCP协议
- udp: UDP协议
- ip4:1: IPv4 ICMP协议
- ip6:ipv6-icmp: IPv6 ICMP协议
- ip6:58: IPv6 ICMPv6协议
- unix: Unix域套接字
- unixgram: Unix数据报套接字
- 以及Go标准库net包支持的其他协议类型
提示
- 每条消息发送前会在内容末尾自动添加换行符'\n'作为消息结束标记
# 配置
字段 | 类型 | 是否必填 | 说明 | 默认值 |
---|---|---|---|---|
protocol | string | 是 | 网络协议类型,如tcp/udp等 | tcp |
server | string | 是 | 服务器地址,格式为host:port,如127.0.0.1:8888或:8888 | 0 |
connectTimeout | int | 否 | 连接超时时间,单位为秒。<=0时使用默认值60秒 | 60 |
heartbeatInterval | int | 否 | 心跳检测间隔,单位为秒。用于定期发送心跳包保持连接活跃。设为0则不发送心跳 | 60 |
# Relation Type
- Success: 消息发送成功时,将消息转发到
Success
链路 - Failure: 以下情况消息发送到
Failure
链路:- 网络连接建立失败
- 发送超时
- 连接断开
- 心跳检测失败
# 执行结果
组件执行后:
- 成功时不修改原始消息内容
- 失败时在metadata中添加error字段描述错误信息
# 配置示例
{
"id": "s1",
"type": "net",
"name": "推送数据",
"configuration": {
"protocol": "tcp",
"server": "127.0.0.1:8888"
}
}
1
2
3
4
5
6
7
8
9
2
3
4
5
6
7
8
9
# 应用示例
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/12/22, 03:38:12