问题描述
我正在尝试使用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 (将#修改为@)