如何解决从EJB连接到Apache Pulsar代理的问题
我正在尝试使用SAP NetWeaver服务器Java上部署的EJB服务连接到Apache Pulsar客户端，下面是我尝试使用客户端证书进行连接时遇到的错误：
org.apache.pulsar.client.api.PulsarClientException：java.util.concurrent.ExecutionException：org.apache.pulsar.client.api.PulsarClientException：java.util.concurrent.CompletionException：java.nio。 channel.ClosedChannelException
当我启用以下跟踪时，是我得到的确切错误：
org.apache.pulsar.shade.io.netty.channel.ChannelInitializer异常捕获 警告：无法初始化频道。结束语：[id：0xa6d91150] java.lang.RuntimeException：无法在org.apache.pulsar.client.util上的org.apache.pulsar.client.impl.PulsarChannelInitializer.lambda $ new $ 0（PulsarChannelInitializer.java:97）上创建TLS上下文。 org.apache.pulsar.client.impl.PulsarChannelInitializer.initChannel（PulsarChannelInitializer.java:114）的org.apache.pulsar.client.impl.PulsarChannelInitializer.initChannel（PulsarChannelInitializer.java：的ObjectCache.get（ObjectCache.java:48） 42）at org.apache.pulsar.shade.io.netty.channel.ChannelInitializer.initChannel（ChannelInitializer.java:129）at org.apache.pulsar.sha.io.netty.channel.ChannelInitializer.handlerAdded（ChannelInitializer.java： 112）at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.callHandlerAdded（AbstractChannelHandlerContext.java:971）at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.callHandlerAdded0（DefaultChannelPipeline.java： 609）at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.access $ 100（DefaultChannelPipeline .java：46）位于org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline $ PendingHandlerAddedTask.execute（DefaultChannelPipeline.java:1463）位于org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.callHandlerAddedForAllHandlers （DefaultChannelPipeline.java:1115）在org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.invokeHandlerAddedIfNeeded（DefaultChannelPipeline.java:650）在org.apache.pulsde.io.netty.channel.AbstractChannel $ AbstractUnsafe org.apache.pulsar.shade.io.netty.channel.AbstractChannel $ AbstractUn $ .register0（AbstractChannel.java:502）.org.apache.pulsar.shade.io.netty.channel.AbstractChannel $ AbstractUnsafe.register（AbstractChannel.java:468）at org.apache.pulsar.shade.io.netty.channel .org.apache.pulsar.shade.io.netty.channel上的.SingleThreadEventLoop.register（SingleThreadEventLoop.java:87）在org.apache.pulsar.shade.io.netty.channel上的.SingleThreadEventLoop.register（SingleThreadEventLoop.java:81） .org.apache.pulsar.shade.io.netty.bootstrap.AbstractBootst中的.MultithreadEventLoopGroup.register（MultithreadEventLoopGroup.java:86） org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect（Bootstrap.java:155）上的rap.initAndRegister（AbstractBootstrap.java:323）在org.apache.pulsar.shade.io.netty.bootstrap上。 org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.connect（Bootstrap.java:130）的org.apache.pulsar.client.impl.ConnectionPool.connectToAddress（的Bootstrap.connect（Bootstrap.java:139）） org.apache.pulsar.client.impl.ConnectionPool.connectToResolvedAddresses（ConnectionPool.java:248）处org.apache.pulsar.client.impl.ConnectionPool.lambda $ createConnection $ 11（ConnectionPool.java:234） ）java.util.concurrent.CompletableFuture.uniCompose（CompletableFuture.java:952）at java.util.concurrent.CompletableFuture $ UniCompose.tryFire（CompletableFuture.java:926）at java.util.concurrent.CompletableFuture.postComplete（CompletableFuture。 java：474）在org.apache.pulsar.client.impl.ConnectionPool.lambda $ resolveName $ 16（Connec）在java.util.concurrent.CompletableFuture.complete（CompletableFuture.java:1962） org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0（DefaultPromise.java:577）上的tionPool.java:276）org.apache.pulsar.shade.io.netty.util.concurrent上的tionPool.java:276）。 org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow（DefaultPromise.java:551）位于org.apache.pulsar.shade.io.netty的DefaultPromise.notifyListeners（DefaultPromise.java:490）。 org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0（DefaultPromise.java:604）上的util.concurrent.DefaultPromise.setValue0（DefaultPromise.java:615）在org.apache.pulsar.shade处。 io.netty.util.concurrent.DefaultPromise.trySuccess（DefaultPromise.java:104）在org.apache.pulsar.shade.io.netty.resolver.dns.DnsResolveContext $ 1.operationComplete（DnsResolveContext.java:218）在org.apache org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow（DefaultPromise.java:551）上的.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0（DefaultPromise.java:577）在org.apache.pulsar。在org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0（DefaultPromise.java:615）处的shade.io.netty.util.concurrent.DefaultPromise.notifyListeners（DefaultPromise.java:490）在org。 apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0（DefaultPromise.java:604）在org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess（DefaultPromise.java:104 ）at org.apache.pulsar.shade.io.netty.resolver.dns.DnsNameResolver.trySuccess（DnsNameResolver.java:919）at org.apache.pulsar.shade.io.netty.resolver.dns.DnsResolveContext.finishResolve（DnsResolveContext .java：904）位于org.apache.pulsar.shade.io.netty.resolver.dns.DnsResolveContext上org.apache.pulsar.shade.io.netty.resolver.dns.DnsResolveContext.tryToFinishResolve（DnsResolveContext.java:884）在org.apache.pulsar.shade.io.netty.resolver.dns.DnsResolveContext $ 2.operationComplete（DnsResolveContext.java:409）在org.apache.pulsar.shade.io.netty的.access $ 700（DnsResolveContext.java:64） .util.concurrent.DefaultPromise.n org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners0（DefaultPromise.java:570）上的otifyListener0（DefaultPromise.java:577）在org.apache.pulsar.shade.io.netty.util上。 org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners（DefaultPromise.java:490）上的并发DefaultPromise.notifyListenersNow（DefaultPromise.java:549）在org.apache.pulsar.shade.io处org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0（DefaultPromise.java:604）的org.apache.pulsar.netty.net.util.concurrent.DefaultPromise.setValue0（DefaultPromise.java:615）在org.apache.pulsar.shade.io.netty.resolver.dns.DnsQueryContext.trySuccess（DnsQueryContext.java:201）处的shade.io.netty.util.concurrent.DefaultPromise.trySuccess（DefaultPromise.java:104）在组织中apache.pulsar.shade.io.netty.resolver.dns.DnsQueryContext.finish（DnsQueryContext.java:193）at org.apache.pulsar.shade.io.netty.resolver.dns.DnsNameResolver $ DnsResponseHandler.channelRead（DnsNameResolver.java ：1215）在org.apa org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:365）处的che.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:379） apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead（AbstractChannelHandlerContext.java:357）at org.apache.pulsar.shade.io.netty.handler.codec.MessageToMessageDecoder.channelRead（MessageToMessageDecoder.java:102）at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:379）at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:365）at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline $ HeadContext.channelRead（DefaultChannelPipe）上的org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead（AbstractChannelHandlerContext.java:357） line.java:1410）在org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（AbstractChannelHandlerContext.java:379）在org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead（ org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead（DefaultChannelPipeline.java:919）中的AbstractChannelHandlerContext.java:365）org.apache.pulsar.shade.io.netty.channel.epoll.EpollDatagramChannel。在org.apache.pulsar.shade.io.netty.channel.epoll.EpollDatagramChannel.access处读取（EpollDatagramChannel.java:679）在org.apache.pulsar.shade.io.netty.channel上读取$ 100（EpollDatagramChannel.java:58） org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollChannel $ AbstractEpollUnsafe $ 1.run（AbstractEpollChannel.java:387）的.epoll.EpollDatagramChannel $ EpollDatagramChannelUnsafe.epollInReady（EpollDatagramChannel.java:497）。 org上的pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute（AbstractEventExecutor.java:164） .apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks（SingleThreadEventExecutor.java:472）位于org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run（EpollEventLoop.java： 384）at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor $ 4.run（SingleThreadEventExecutor.java:989）at org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap $ 2。在org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run（FastThreadLocalRunnable.java:30）处运行（ThreadExecutorMap.java:74）在java.lang.Thread.run（Thread.java:836） 由以下原因引起：org.apache.pulsar.client.impl.auth.AuthenticationTls.getAuthData（AuthenticationTls。org.apache.pulsar.client.api.PulsarClientException：java.security.KeyManagementException：证书加载错误。 java：82）at org.apache.pulsar.client.impl.PulsarChannelInitializer.lambda $ new $ 0（PulsarChannelInitializer.java:87）... 78更多 由以下原因引起：java.security.KeyManagementException：证书加载错误位于 org.apache.pulsar.client.impl上的org.apache.pulsar.common.util.SecurityUtility.loadCertificatesFromPemFile（SecurityUtility.java:249） .org.apache.pulsar.client.impl.auth.AuthenticationTls.getAuthData（AuthenticationTls.java:77）的.auth.AuthenticationDataTls。（AuthenticationDataTls.java:55）... 79更多 原因：java.io.FileNotFoundException：版本：3
此处有证书数据...隐藏
扩展名：7 （文件名太长）在java.io.FileInputStream.open 处为0（本机方法）在java.io.FileInputStream.open（FileInputStream.java:195）处在java.io.FileInputStream。（FileInputStream.java： 138），位于org.apache.pulsar.common.util.SecurityUtility.loadCertificatesFromPemFile（SecurityUtility.java:246）的java.io.FileInputStream。（FileInputStream.java:93）...上另外81个“
有人可以帮我吗？
以下是代码段： 我们将证书存储在密钥存储视图中的SAP Netweaver AS Java服务器中，并从那里以编程方式检索：
package com.verizon.ejb.adapter;
import java.security.KeyStore;
import java.security.cert.Certificate;
import java.security.cert.X509Certificate;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Map;
import javax.naming.InitialContext;
import org.apache.pulsar.client.api.Authentication;
import org.apache.pulsar.client.api.AuthenticationFactory;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.impl.auth.AuthenticationTls;
import com.sap.aii.af.service.resource.SAPSecurityResources;
import com.sap.aii.security.lib.KeyStoreManager;
import com.sap.aii.security.lib.PermissionMode;
import com.sap.security.api.ssf.ISsfProfile;
import com.sap.tc.logging.Location;
public class PulsarClientImpl {
private static final Location log = Location.getLocation(PulsarClientImpl.class);
private PulsarClientImpl() {
}
private static class PulsarClientObject {
private static final PulsarClient pulsarClient;
private static Integer count = 0;
static {
try {
Map<String,String> authParams = new HashMap<>();
log.errorT("Pulsar client impl");
InitialContext ctx = new InitialContext();
KeyStoreManager mgr =SAPSecurityResources.getInstance().getKeyStoreManager(
PermissionMode.SYSTEM_LEVEL,new String[]{ "sap.com/PulsarEjbAdapterEAR" });
KeyStore keyStore =mgr.getKeyStore("Pulsar_Certs");
String[] keyStores = mgr.getKeyStoreAliases(keyStore);
Enumeration aliases = null;
KeyStore keyStoree = null;
String tlsCertFileName = null;
String tlsTrustFileName = null;
java.security.PrivateKey tlsSecCertPrivateKey=null;
for(int i = 0; i < keyStores.length; i++){
keyStoree = mgr.getKeyStore(keyStores[i]);
aliases = keyStoree.aliases();
log.errorT("pulsar key store aliases"+aliases);
log.errorT("pulsatr key store"+keyStoree.toString());
ISsfProfile tlsSecCertPrivKeyProf = mgr.getISsfProfile(keyStore,"gqzvkey-key",null);
tlsSecCertPrivateKey = tlsSecCertPrivKeyProf.getPrivateKey();
Certificate cert[] = tlsSecCertPrivKeyProf.getCertificateChain();
for (Certificate x509Certificate : cert) {
if(tlsTrustFileName ==null)
{
tlsTrustFileName=x509Certificate.toString();
}else
if(tlsCertFileName==null)
{
tlsCertFileName=x509Certificate.toString();
}
}
}
log.errorT("tlsCertFileName:::"+tlsCertFileName);
log.errorT("tlsTrustFileName:::"+tlsTrustFileName);
authParams.put("tlsCertFile",tlsCertFileName);
authParams.put("tlsKeyFile",tlsSecCertPrivateKey.toString());
Authentication tlsAuth;
tlsAuth = AuthenticationFactory.create(AuthenticationTls.class.getName(),authParams);
log.errorT("After creating tls auth" + tlsAuth);
pulsarClient = PulsarClient.builder()
.serviceUrl("pulsar+ssl://xxxxx.xxx.com:6651")
.tlsTrustCertsFilePath(tlsTrustFileName).authentication(tlsAuth).build();
log.errorT("After creating pulsar client" + pulsarClient);
System.out.println("Pulsar Client : " + pulsarClient.toString());
log.errorT("Pulsar Client : " + pulsarClient.toString());
log.errorT("Pulsar Client Count : " + count++);
} catch (Exception e) {
log.errorT("client error" + e.getMessage());
e.printStackTrace();
throw new ExceptionInInitializerError(e);
}
}
}
public static PulsarClient getInstance() {
return PulsarClientObject.pulsarClient;
}
/*public String getTheValueOfProperty(String stringKeyOfProperty) {
return ApplicationPropertiesHandler.getInstance().getStringValue(stringKeyOfProperty);
}*/
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
