OPC Foundation NETStandard标签采集代码修正与连接问题排查

1. 按现有参数建立OPC UA连接 #

错误原因分析 #

• Endpoint doesn't support the user identity type provided：你误用了证书作为用户身份认证方式，但KEPServer当前未启用证书类型的身份认证；UaExpert提示找不到私钥，是因为客户端缺少带私钥的证书（用于OPC UA通道的签名/加密），而KEPServer要求信任的客户端证书为DER格式（仅公钥），两者并不冲突。

解决步骤 #

1. 确认KEPServer身份认证配置
   登录KEPServer管理界面，检查OPC UA服务器的身份认证设置：

   • 如果仅开启了匿名或用户名/密码认证，客户端不能用CertificateUserIdentity创建会话，需切换对应身份类型。
   • 通道安全（证书加密）和用户身份认证是两个独立环节：KEPServer要求的DER证书是用于信任客户端的公钥，客户端自身必须持有带私钥的PFX证书用于通信加密。

2. 修正客户端代码配置

   • 加载客户端带私钥的PFX证书：确保ApplicationConfiguration中正确指定客户端证书的PFX路径和密码（如果有）。
   • 选择服务器支持的安全策略（如SecurityPolicy.Basic256Sha256）。
   • 切换正确的用户身份类型：

     // 示例：如果服务器允许匿名认证
     var userIdentity = new UserIdentity();
     // 示例：如果服务器用用户名密码认证
     // var userIdentity = new UserIdentity("username", "password");
     

   • 不要使用CertificateUserIdentity，除非KEPServer明确开启了证书身份认证。

3. UaExpert测试修正

   • 在UaExpert中导入客户端带私钥的PFX证书，导出其DER格式的公钥提交给KEPServer管理员加入信任列表；
   • 连接时选择对应身份认证类型（匿名/用户名密码），即可解决找不到私钥的问题。

2. 证书有效期设置与更新 #

• 自定义证书有效期：使用UA-.NETStandard的CertificateGenerator生成客户端证书时，可通过NotBefore和NotAfter参数指定有效期，无需每年更新：

  var generator = new CertificateGenerator();
  generator.NotBefore = DateTime.UtcNow;
  generator.NotAfter = DateTime.UtcNow.AddYears(5); // 设置5年有效期
  // 其他证书配置...
  var certificate = generator.CreateCertificate();
  

• 证书到期处理：证书到期后，需重新生成新证书，导出DER格式公钥提交给KEPServer替换旧信任证书，客户端更新PFX证书即可，无需修改代码逻辑。

3. 关联标签ID与采集数据 #

在采集数据时，通过MonitoredItem或ReadValueId的UserData属性绑定标签ID，实现数据与标签的关联：

订阅采集场景 #

// 创建MonitoredItem时绑定标签ID
var nodeId = new NodeId("ns=2;s=YourTag");
var monitoredItem = new MonitoredItem(new ReadValueId(nodeId, Attributes.Value), MonitoringMode.Reporting)
{
    UserData = "TAG_0001" // 存储你的业务标签ID，也可以是自定义对象
};

// 数据变更回调中获取标签ID
private void OnDataChangeNotification(object sender, DataChangeNotificationEventArgs e)
{
    foreach (var item in e.NotificationMessage.MonitoredItems)
    {
        var monitoredItem = (MonitoredItem)item.ClientHandle;
        var tagId = monitoredItem.UserData.ToString();
        var tagValue = item.Value.Value;
        
        // 将tagId和tagValue一起写入数据库
        // InsertIntoDatabase(tagId, tagValue);
    }
}

批量读取场景 #

// 构建读取请求时绑定标签ID
var readRequests = new List<ReadValueId>();
var tagMapping = new Dictionary<ReadValueId, string>();

var tag1Node = new NodeId("ns=2;s=Tag1");
var readId1 = new ReadValueId(tag1Node, Attributes.Value);
readRequests.Add(readId1);
tagMapping.Add(readId1, "TAG_0001");

// 执行读取后匹配标签ID
var readResult = session.Read(null, 0, TimestampsToReturn.Both, readRequests);
foreach (var result in readResult.Results)
{
    var readId = readRequests[Array.IndexOf(readResult.Results, result)];
    var tagId = tagMapping[readId];
    var tagValue = result.Value.Value;
    
    // 写入数据库逻辑
}

内容的提问来源于stack exchange，提问作者Anthony Voronkov