Я пытаюсь создавать серверные и клиентские приложения на Java с безопасным соединением SSL (TLS) и двусторонней аутентификацией SSL. Односторонний SSL (без аутентификации клиента) работает хорошо. При включенной аутентификации клиента клиент не может выполнить рукопожатие за исключением:
sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
Сервер не имеет никаких исключений. Я использую Netty на сервере и клиенте. Я использую самозаверяющие сертификаты для сервера и клиента. Сервер и клиент - теперь это один физический хост. Я уже добавил сертификат сервера в хранилище доверенных сертификатов с помощью этого инструмента:
https://java-use-examples.googlecode.com/svn/trunk/src/com/aw/ad/util/InstallCert.java
Код клиента. Главный.
public class SClientApp {
public static final String HOST = "127.0.0.1";
public static final int PORT = 8888;
public static void main(String[] args) throws Exception {
System.setProperty("javax.net.ssl.trustStore", "/etc/ssl/certs/java/cacerts");
System.setProperty("javax.net.ssl.trustStorePassword", "changeit");
// Configure SSL (TLS)
File tls_cert = new File("tls/client1.pem");
SslContext sslCtx = null;
try {
sslCtx = SslContext.newClientContext(tls_cert);
} catch (SSLException e) {
e.printStackTrace();
}
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group)
.channel(NioSocketChannel.class)
.handler(new SClientInitializer(sslCtx));
// Start the connection attempt.
Channel ch = b.connect(HOST, PORT).sync().channel();
...
} finally {
// The connection is closed automatically on shutdown.
group.shutdownGracefully();
}
}
}
Код клиента. SClientInitializer.
public class SClientInitializer extends ChannelInitializer<SocketChannel> {
private final SslContext sslCtx;
public SClientInitializer(SslContext sslCtx) {
this.sslCtx = sslCtx;
}
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
SSLEngine ssl_engine = sslCtx.newEngine(ch.alloc(), SClientApp.HOST, SClientApp.PORT);
ssl_engine.setUseClientMode(true);
pipeline.addLast(new SslHandler(ssl_engine));
// On top of the SSL handler, add the text line codec.
pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
pipeline.addLast(new StringDecoder());
pipeline.addLast(new StringEncoder());
// and then business logic.
pipeline.addLast(new SClientHandler());
}
}
Код сервера. Главный.
public class ServerApp {
static final int PORT = Integer.valueOf(Params.get(Const.SERVER_PORT));
public static void main(String[] args) {
System.setProperty("javax.net.ssl.trustStore", "/etc/ssl/certs/java/cacerts");
System.setProperty("javax.net.ssl.trustStorePassword", "changeit");
// Configure SSL (TLS)
File tls_cert = new File("tls/server.pem"); // SSL-cert
File tls_key = new File("tls/server.key.pkcs8"); // Private key
SslContext sslCtx = null;
try {
sslCtx = SslContext.newServerContext(tls_cert, tls_key);
} catch (SSLException e) {
e.printStackTrace();
}
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup(2);
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ServerNetInitializer(sslCtx));
ChannelFuture f = null;
try {
f = b.bind(PORT).sync();
f.channel().closeFuture().sync();
} catch (InterruptedException e) {
e.printStackTrace();
}
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
Код сервера. Инициализатор.
public class ServerNetInitializer extends ChannelInitializer<SocketChannel> {
private final SslContext sslCtx;
public ServerNetInitializer(SslContext sslCtx) {
this.sslCtx = sslCtx;
}
@Override
protected void initChannel(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline();
SSLEngine ssl_engine = sslCtx.newEngine(ch.alloc());
ssl_engine.setUseClientMode(false);
ssl_engine.setNeedClientAuth(true);
pipeline.addLast(new SslHandler(ssl_engine));
// On top of the SSL handler, add the text line codec.
pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
pipeline.addLast(new StringDecoder());
pipeline.addLast(new StringEncoder());
// and then business logic.
pipeline.addLast(new ServerNetHandler());
}
}
Обновление 1.
Мне помогают классы JdkSslClientContext и JdkSslServerContext.
На стороне сервера:
sslCtx = new JdkSslServerContext(client_tls_cert, null,
server_tls_cert, server_tls_key, "", null,
null, IdentityCipherSuiteFilter.INSTANCE, (ApplicationProtocolConfig) null, 0, 0);
На стороне клиента:
sslCtx = new JdkSslClientContext(server_tls_cert,null,client_tls_cert,client_tls_key,"", null, null,IdentityCipherSuiteFilter.INSTANCE,(ApplicationProtocolConfig) null,0,0);
Пример кода здесь: https://github.com/netty/netty/blob/master/handler/src/test/java/io/netty/handler/ssl/JdkSslEngineTest.java
Обновление 2
На стороне сервера лучше использовать TrustManagerFactory вместо объекта File клиентского сертификата, потому что у вас может быть много клиентов:
KeyStore ts = null;
ts = KeyStore.getInstance("JKS");
ts.load(new FileInputStream(System.getProperty("javax.net.ssl.trustStore")),
System.getProperty("javax.net.ssl.trustStorePassword").toCharArray());
// set up trust manager factory to use our trust store
TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
tmf.init(ts);
SslContext sslCtx = null;
try {
sslCtx = new JdkSslServerContext(null, tmf,
server_tls_cert, server_tls_key, "", null,
null, IdentityCipherSuiteFilter.INSTANCE, (ApplicationProtocolConfig) null, 0, 0);
} catch (SSLException e) {
log.error("Making ssl context for server - Exception: " + e.toString());
e.printStackTrace();
}