看来你卡在自定义结构体的编解码注册和读写上了，我帮你一步步排查问题，再给你一套规范的可落地实现方案。

先分析你遇到的核心问题 #

你抛出的no codec registered for encodingId=ns=4;i=29异常，本质是客户端的编码上下文里还没有注册对应自定义类型的编解码器，大概率是这几个原因：

1. 编解码器注册时机太晚，等到读写操作时才注册，客户端已经初始化完成
2. 自定义类型的BINARY_ENCODING_ID和服务器端定义的ns=4;i=29不匹配
3. 编解码器注册的方式不对，没有关联到正确的会话/编码上下文

修正后的完整实现步骤 #

第一步：先确认自定义类型的ID常量正确性

首先要保证你的LoadColli类里的类型ID、二进制编码ID和服务器端完全一致，服务器端的自定义类型NodeId可以用UA Expert工具查看：

public class LoadColli {
    // 服务器端自定义类型的NodeId，比如ns=4;i=xxx
    public static final ExpandedNodeId TYPE_ID = ExpandedNodeId.parse("ns=4;i=xxx");
    // 错误提示里的encodingId是ns=4;i=29，必须和这个完全匹配
    public static final ExpandedNodeId BINARY_ENCODING_ID = ExpandedNodeId.parse("ns=4;i=29");

    private final String id;
    private boolean finished;
    private boolean inProgress;

    // 构造方法、getter/setter要齐全
    public LoadColli(boolean finished, boolean inProgress, String id) {
        this.finished = finished;
        this.inProgress = inProgress;
        this.id = id;
    }

    public String getId() { return id; }
    public boolean isFinished() { return finished; }
    public void setFinished(boolean finished) { this.finished = finished; }
    public boolean isInProgress() { return inProgress; }
    public void setInProgress(boolean inProgress) { this.inProgress = inProgress; }
}

第二步：编解码器实现要规范

注意字段名要和服务器端自定义类型的字段名完全一致（大小写敏感）：

public static class LoadColliCodec extends GenericDataTypeCodec<LoadColli> {
    @Override
    public Class<LoadColli> getType() {
        return LoadColli.class;
    }

    @Override
    public LoadColli decodeType(EncodingContext context, UaDecoder decoder) throws UaSerializationException {
        // 字段名必须和服务器端定义的一模一样
        String id = decoder.decodeString("ID");
        boolean finished = decoder.decodeBoolean("Finished");
        boolean inProgress = decoder.decodeBoolean("InProgress");
        return new LoadColli(finished, inProgress, id);
    }

    @Override
    public void encodeType(EncodingContext context, UaEncoder encoder, LoadColli value) throws UaSerializationException {
        encoder.encodeString("ID", value.getId());
        encoder.encodeBoolean("Finished", value.isFinished());
        encoder.encodeBoolean("InProgress", value.isInProgress());
    }
}

第三步：提前注册编解码器（关键！）

必须在客户端连接成功后立刻注册，不能等到读写时才注册，否则客户端的编码上下文里还没有这个编解码器：

private void registerCustomCodec(OpcUaClient client) {
    // 把ExpandedNodeId转成当前会话的NodeId
    NodeId dataTypeId = LoadColli.TYPE_ID
        .toNodeId(client.getNamespaceTable())
        .orElseThrow(() -> new IllegalStateException("自定义类型的命名空间未找到"));
    NodeId binaryEncodingId = LoadColli.BINARY_ENCODING_ID
        .toNodeId(client.getNamespaceTable())
        .orElseThrow(() -> new IllegalStateException("自定义类型的二进制编码ID未找到"));

    LoadColliCodec codec = new LoadColliCodec();

    // 同时注册到会话级和全局静态的DataTypeManager，确保上下文都能找到
    // 会话级：当前连接专属，优先使用
    client.getDataTypeManager().registerCodec(dataTypeId, binaryEncodingId, codec);
    // 全局静态：所有客户端实例都能复用
    client.getStaticDataTypeManager().registerType(
        dataTypeId, codec, binaryEncodingId, null, null // xml/json编码ID不需要可以传null
    );
}

// 客户端连接流程示例
public void initClient() throws Exception {
    String endpointUrl = "opc.tcp://your-server-ip:port/endpoint";
    OpcUaClientConfig config = OpcUaClientConfig.builder()
        .setEndpoint(endpointUrl)
        .setIdentityProvider(new AnonymousProvider())
        .setRequestTimeout(UInteger.valueOf(5000))
        .build();

    OpcUaClient client = OpcUaClient.create(config);
    // 连接成功后立刻注册编解码器
    client.connect().thenAccept(session -> {
        registerCustomCodec(client);
    }).get(); // 同步等待连接完成，也可以用异步回调

    // 这里再执行你的读写逻辑
    readAndWriteLoadColli(client);
}

第四步：简化读写逻辑（不需要手动解码）

只要编解码器注册正确，Milo会自动解码Variant里的ExtensionObject，不需要手动调用xo.decode()：

private void readAndWriteLoadColli(OpcUaClient client) throws Exception {
    NodeId nodeId = NodeId.parse("ns=4;i=30");
    UaVariableNode targetNode = client.getAddressSpace().getVariableNode(nodeId);

    // 1. 读取自定义结构体
    DataValue readValue = targetNode.readValue().get();
    Variant readVariant = readValue.getValue();
    // 编解码器注册正确的话，直接强转即可
    LoadColli loadColli = (LoadColli) readVariant.getValue();

    // 2. 修改结构体属性
    loadColli.setFinished(true);
    loadColli.setInProgress(false);

    // 3. 写入修改后的结构体
    ExtensionObject writeXo = ExtensionObject.encode(
        client.getStaticEncodingContext(),
        loadColli,
        LoadColli.TYPE_ID.toNodeId(client.getNamespaceTable()).get(),
        LoadColli.BINARY_ENCODING_ID.toNodeId(client.getNamespaceTable()).get()
    );
    Variant writeVariant = new Variant(writeXo);
    DataValue writeDataValue = new DataValue(writeVariant, null, null);

    targetNode.writeValue(writeDataValue).get();
    log.info("自定义结构体读写完成");
}

最后再给你几个排查小技巧 #

1. 用UA Expert工具确认服务器端自定义类型的NodeId、二进制编码ID、字段名，确保和你的代码完全一致
2. 如果还是报错，开启Milo的DEBUG日志，查看服务器返回的ExtensionObject的encodingId是不是你注册的ns=4;i=29
3. 不要等到读写时才注册编解码器，必须在连接成功后第一时间注册
4. 字段名是大小写敏感的，比如服务器端定义的是ID，你不能写成id