network framework written with native c, support latest openssl(gmssl) 1.3 support encrypted key and encrypted certificate
String root = getCurrentWorkDir();
String ca = root + "crt/ca.crt";
String key = root + "crt/server.key";
String crt = root + "crt/server.crt";
String enkey = root + "crt/server_en.key";
String encrt = root + "crt/server_en.crt";
String clikey = root + "crt/cli.key";
String clicrt = root + "crt/cli.crt";
String enclikey = root + "crt/cli_en.key";
String enclicrt = root + "crt/cli_en.crt";
//event loop
HandlerList handlerlist = new HandlerList();
handlerlist.add(
new FrameReadHandler(0, 2, 2),
new AbstractWrappedHandler<Msg>() {
@Override
public void onMessage(ChannelContext ctx, Msg input) {
System.out.println("Handler: receive: " + input.data);
}
@Override
public Msg decode(Bytes in) {
Msg msg = new Msg();
msg.decode(in);
return msg;
}
@Override
public void onConnect(ChannelContext ctx) {
Channel channel = ctx.channel();
String host = channel.remoteHost();
int port = channel.remotePort();
System.out.println("Handler: " + host+":"+port+" connected.");
ctx.write(new Msg());
}
@Override
public void onDisconnect(ChannelContext ctx) {
Channel channel = ctx.channel();
String host = channel.remoteHost();
int port = channel.remotePort();
System.out.println("Handler: " + host+":"+port+" disconnected.");
}
@Override
public void onError(ChannelContext ctx, Throwable t) {
t.printStackTrace();
}
@Override
public void onAccept(ChannelContext ctx) {
Channel channel = ctx.channel();
String host = channel.remoteHost();
int port = channel.remotePort();
System.out.println(host+":"+port+" accepted.");
}
});
try {
//ca crt
byte[] caBytes= Files.readAllBytes(Paths.get(ca));
//server crt
byte[] crtBytes= Files.readAllBytes(Paths.get(crt));
byte[] keyBytes= Files.readAllBytes(Paths.get(key));
byte[] enCrtBytes= Files.readAllBytes(Paths.get(encrt));
byte[] enKeyBytes= Files.readAllBytes(Paths.get(enkey));
//client crt
byte[] clicrtBytes= Files.readAllBytes(Paths.get(clicrt));
byte[] clikeyBytes= Files.readAllBytes(Paths.get(clikey));
byte[] enClicrtBytes= Files.readAllBytes(Paths.get(enclicrt));
byte[] enClikeyBytes= Files.readAllBytes(Paths.get(enclikey));
//start a gmssl server
System.out.println("start server.");
SslContext opt = new SslContext(false, true).trustCertificateAuth(caBytes).useCertificate(crtBytes, keyBytes).useEncryptCertificate(enClicrtBytes, enClikeyBytes);
ServerChannel server = new ServerChannel(opt);
server.handlerList(handlerlist);
server.listen("127.0.0.1", 8081);
// wait
Thread.sleep(1000);
//start a gmssl client
SslContext cliopt = new SslContext(true, false).trustCertificateAuth(caBytes).useCertificate(clicrtBytes, clikeyBytes).useEncryptCertificate(enClicrtBytes, enClikeyBytes);
Channel cli = new Channel(cliopt);
cli.handlerList(handlerlist);
cli.connect("127.0.0.1", 8081);
//wait
Thread.sleep(2000);
//close client
cli.close();
} catch (Exception e) {
e.printStackTrace();
} String root = getCurrentWorkDir();
String ca = root + "crt/ca.crt";
String key = root + "crt/server.key";
String crt = root + "crt/server.crt";
String enkey = root + "crt/server_en.key";
String encrt = root + "crt/server_en.crt";
byte[] crtBytes= Files.readAllBytes(Paths.get(crt));
byte[] keyBytes= Files.readAllBytes(Paths.get(key));
byte[] enCrtBytes= Files.readAllBytes(Paths.get(encrt));
byte[] enKeyBytes= Files.readAllBytes(Paths.get(enkey));
System.out.println("start server.");
HandlerList handlerlist = new HandlerList();
handlerlist.add(new HttpWrappedHandler() {
@Override
public void handle(HttpRequest req, HttpResponse res) throws Exception {
String uri = req.getUri();
res.setContentType(ContentType.APPLICATION_JSON);
if(uri.equals("/nihao")) {
res.setStatus(HttpStatus.OK);
res.setContent("{\"nihao\":\"ni\"}".getBytes());
} else {
res.setStatus(HttpStatus.NOT_FOUND);
res.setContent("{\"nihao\":\"ni\"}".getBytes());
}
}
@Override
public void handleException(HttpRequest req, HttpResponse res, Throwable t) {
t.printStackTrace();
String body = "{" +
"\"server\": \"Java/"+System.getProperty("java.version")+"\"," +
"\"time\": \"" + LocalDateTime.now().toString() + "\"," +
"\"status\": \"" + HttpStatus.SERVICE_UNAVAILABLE.getStatus() + "\"" +
"}";
res.setStatus(HttpStatus.SERVICE_UNAVAILABLE);
res.setContentType(ContentType.APPLICATION_JSON);
res.setContent(body.getBytes());
}
});
SslContext opt = new SslContext().trustCertificateAuth(caBytes).useCertificate(crtBytes, keyBytes);
ServerChannel server = new ServerChannel(opt);
server.handlerList(handlerlist);
server.listen(8080);or
String root = getCurrentWorkDir();
String ca = root + "crt/ca.crt";
String key = root + "crt/server.key";
String crt = root + "crt/server.crt";
String enkey = root + "crt/server_en.key";
String encrt = root + "crt/server_en.crt";
try {
byte[] caBytes= Files.readAllBytes(Paths.get(ca));
byte[] crtBytes= Files.readAllBytes(Paths.get(crt));
byte[] keyBytes= Files.readAllBytes(Paths.get(key));
byte[] enCrtBytes= Files.readAllBytes(Paths.get(encrt));
byte[] enKeyBytes= Files.readAllBytes(Paths.get(enkey));
System.out.println("start server.");
SslContext opt = new SslContext(false).trustCertificateAuth(caBytes).useCertificate(crtBytes, keyBytes).useEncryptCertificate(enCrtBytes, enKeyBytes);
HttpServer server = new HttpServer(opt);
server.listen("127.0.0.1", 8081, new HttpWrappedHandler() {
@Override
public void handle(HttpRequest req, HttpResponse res) throws Exception {
//do something here
}
@Override
public void handleException(HttpRequest req, HttpResponse res, Throwable t) {
t.printStackTrace();
}
});
} catch(Exception e) {
e.printStackTrace();
} NativeResponse baidu = NativeRequest.get("https://www.baidu.com");
System.out.println(baidu.getStatus());
System.out.println(new String(baidu.getBody()));
//request localhost (above server)
String root = getCurrentWorkDir();
String ca = root + "crt/ca.crt";
NativeResponse localhost = NativeRequest.get("https://127.0.0.1:8080/hihao", new NativeRequest.Options().caPath(ca));
System.out.println(localhost.getStatus());
System.out.println(new String(localhost.getBody()));