import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
public CompletableFuture<UaClient> connect(String url, EndpointDescription endpoint) {
  clientHandles.set(0);
  endpointDescription.set(endpoint);

  logger.debug("use endpoint: {} [{}]", endpointDescription.get().getEndpointUrl(), endpointDescription.get().getSecurityMode());

  if (!url.equals(endpointDescription.get().getEndpointUrl())) {
    logger.warn("fix search (returned) endpoint url missmatch: {} ({})", url, endpointDescription.get().getEndpointUrl());
    endpointDescription.set(changeEndpointUrl(endpointDescription.get(), url));
  }
  List<IdentityProvider> idProv = new ArrayList<>();
  getIdentityProvider().ifPresent(idProv::add);
  idProv.add(new AnonymousProvider());

  OpcUaClientConfig config = OpcUaClientConfig.builder().setApplicationName(LocalizedText.english(name)).setApplicationUri("urn:comtel:opcua:client")
      .setEndpoint(endpointDescription.get()).setIdentityProvider(new CompositeProvider(idProv)).setRequestTimeout(uint(5000))
      .build();

  return newClient(config).thenCompose(c -> c.connect());
}
 

import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
@Test
public void testCopy() {
    OpcUaClientConfig original = OpcUaClientConfig.builder()
        .setSessionName(() -> "testSessionName")
        .setSessionTimeout(uint(60000 * 60))
        .setRequestTimeout(uint(120000))
        .setMaxResponseMessageSize(UInteger.MAX)
        .setMaxPendingPublishRequests(uint(2))
        .setIdentityProvider(new AnonymousProvider())
        .setBsdParser(new GenericBsdParser())
        .build();

    OpcUaClientConfig copy = OpcUaClientConfig.copy(original).build();

    assertEquals(copy.getSessionName(), original.getSessionName());
    assertEquals(copy.getSessionTimeout(), original.getSessionTimeout());
    assertEquals(copy.getRequestTimeout(), original.getRequestTimeout());
    assertEquals(copy.getMaxResponseMessageSize(), original.getMaxResponseMessageSize());
    assertEquals(copy.getMaxPendingPublishRequests(), original.getMaxPendingPublishRequests());
    assertEquals(copy.getIdentityProvider(), original.getIdentityProvider());
    assertEquals(copy.getBsdParser(), original.getBsdParser());
}
 

import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
@Test
public void testCopyAndModify() {
    OpcUaClientConfig original = OpcUaClientConfig.builder()
        .setSessionName(() -> "testSessionName")
        .setSessionTimeout(uint(60000 * 60))
        .setRequestTimeout(uint(120000))
        .setMaxResponseMessageSize(UInteger.MAX)
        .setMaxPendingPublishRequests(uint(2))
        .setIdentityProvider(new AnonymousProvider())
        .build();

    OpcUaClientConfig copy = OpcUaClientConfig.copy(original,
        builder ->
            builder.setSessionName(() -> "foo")
                .setSessionTimeout(uint(0))
                .setRequestTimeout(uint(0))
                .setMaxResponseMessageSize(uint(0))
                .setMaxPendingPublishRequests(uint(0))
                .setIdentityProvider(new AnonymousProvider())
                .setBsdParser(new GenericBsdParser())
    );

    assertNotEquals(copy.getSessionName(), original.getSessionName());
    assertNotEquals(copy.getIdentityProvider(), original.getIdentityProvider());
    assertNotEquals(copy.getBsdParser(), original.getBsdParser());

    assertEquals(copy.getSessionTimeout(), uint(0));
    assertEquals(copy.getRequestTimeout(), uint(0));
    assertEquals(copy.getMaxResponseMessageSize(), uint(0));
    assertEquals(copy.getMaxPendingPublishRequests(), uint(0));
}
 

import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
@Override
public IdentityProvider toProvider() {
    return new AnonymousProvider();
}
 

import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
default IdentityProvider getIdentityProvider() {
    return new AnonymousProvider();
}
 

import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; //导入依赖的package包/类
private OpcUaClient createClient() throws Exception {
  SecurityPolicy securityPolicy = conf.securityPolicy.getSecurityPolicy();

  EndpointDescription[] endpoints = UaTcpStackClient.getEndpoints(conf.resourceUrl).get();

  EndpointDescription endpoint = Arrays.stream(endpoints)
      .filter(e -> e.getSecurityPolicyUri().equals(securityPolicy.getSecurityPolicyUri()))
      .findFirst().orElseThrow(() -> new StageException(Errors.OPC_UA_01));

  ChannelConfig channelConfig = new ChannelConfig(
      conf.channelConf.maxChunkSize,
      conf.channelConf.maxChunkCount,
      conf.channelConf.maxMessageSize,
      conf.channelConf.maxArrayLength,
      conf.channelConf.maxStringLength
  );
  OpcUaClientConfigBuilder clientConfigBuilder = OpcUaClientConfig.builder()
      .setApplicationName(LocalizedText.english(conf.applicationName))
      .setApplicationUri(conf.applicationUri)
      .setChannelConfig(channelConfig);

  if (!securityPolicy.equals(SecurityPolicy.None)) {
    KeyStore keyStore = conf.tlsConfig.getKeyStore();
    if (keyStore != null) {
      Key clientPrivateKey = keyStore.getKey(conf.clientKeyAlias, conf.tlsConfig.keyStorePassword.get().toCharArray());
      if (clientPrivateKey instanceof PrivateKey) {
        X509Certificate clientCertificate = (X509Certificate) keyStore.getCertificate(conf.clientKeyAlias);
        PublicKey clientPublicKey = clientCertificate.getPublicKey();
        KeyPair clientKeyPair = new KeyPair(clientPublicKey, (PrivateKey) clientPrivateKey);
        clientConfigBuilder.setCertificate(clientCertificate)
            .setKeyPair(clientKeyPair);
      }
    }
  }

  OpcUaClientConfig config = clientConfigBuilder.setEndpoint(endpoint)
      .setIdentityProvider(new AnonymousProvider())
      .setRequestTimeout(uint(conf.requestTimeoutMillis))
      .setSessionTimeout(uint(conf.sessionTimeoutMillis))
      .build();

  return new OpcUaClient(config);
}