| | |
|---|
| | | // 创建一个上下文，并设置 3 秒超时 |
|---|
| | | ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) |
|---|
| | | defer cancel() |
|---|
| | | conn, err := newGetModbusConnection(ctx, ipAddr) |
|---|
| | | conn, err := newModbusConnection(ctx, ipAddr) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("new modbus connection err: %v", err.Error()) |
|---|
| | | return nil, err |
|---|
| | |
|---|
| | | return conn, nil |
|---|
| | | } |
|---|
| | | |
|---|
| | | func newGetModbusConnection(ctx context.Context, ipAddr string) (plc4go.PlcConnection, error) { |
|---|
| | | func newModbusConnection(ctx context.Context, ipAddr string) (plc4go.PlcConnection, error) { |
|---|
| | | // 创建驱动管理器 |
|---|
| | | driverManager := plc4go.NewPlcDriverManager() |
|---|
| | | // 注册TCP传输 |
|---|
