JAX- WSS4J WSS4J在运行时为消息签名添加证书

Question

我需要一个JAX-WS客户机(用wsdl2java生成)来对其消息进行签名，并验证响应消息的签名。它不应该在传输层，而应该在消息层。证书在编译时是未知的(每个用户都有自己的证书并被上传)。

如果是在传输级别，我将使用所需的证书创建一个keystore，并从中创建一个KeyManagerFactory。- Trustfactory将以相同的方式创建，但会被重用。

    val certFactory = CertificateFactory.getInstance("X.509")

    val certStream = getResource("file").openStream().buffered()
    val cert = certFactory.generateCertificate(certStream)

    val clientKeystore = KeyStore.getInstance(KeyStore.getDefaultType())
    clientKeystore.load(null, null)
    clientKeystore.setCertificateEntry("certificate", cert)

    val kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm())
    kmf.init(clientKeystore, "".toCharArray())

    val caCertStream = getResource("file").openStream().buffered()
    val caCert = certFactory.generateCertificate(caCertStream)

    val caKeyStore = KeyStore.getInstance(KeyStore.getDefaultType())
    caKeyStore.load(null, null)
    caKeyStore.setCertificateEntry("ca-certificate", caCert)

    val context = SSLContext.getInstance("TLSv1.2")
    context.init(keyManagerFactory.keyManagers, trustManagerFactory.trustManagers, null)
    requestContext.put(JAXWSProperties.SSL_SOCKET_FACTORY, context.socketFactory)

但是，由于它需要在消息级别，所以我似乎需要使用WSS4J，而且据我所知，它只适用于引用密钥库文件的属性文件。

如何使用WSS4J在消息级别添加用于签名和验证的证书？

Answer 1

我忘了发我的答案，迟到总比不到好。

诀窍是覆盖WSS4JOutInterceptor和WSS4JInInterceptor中的loadCryptoFromPropertiesFile方法。而不是从文件加载它，您只需从您实时创建的任何内容加载它即可。

        val cryptoProvider = Merlin()
        cryptoProvider.setTrustStore(trustKeyStore)
        cryptoProvider.setKeyStore(keystore)

        val fetchClient = ClientProxy.getClient(fetchPort)
        val fetchEndpoint = fetchClient.endpoint

        val wssOut: WSS4JOutInterceptor = object : WSS4JOutInterceptor(outProps) {
            override fun loadCryptoFromPropertiesFile(propFilename: String, reqData: RequestData): Crypto {
                return cryptoProvider
            }
        }
        fetchEndpoint.outInterceptors.add(wssOut)

        val wssIn: WSS4JInInterceptor = object : WSS4JInInterceptor(inProps) {
            override fun loadCryptoFromPropertiesFile(propFilename: String, reqData: RequestData): Crypto {
                return cryptoProvider
            }
        }
        fetchEndpoint.inInterceptors.add(wssIn)