java ssl通讯程序

import java.io.*; import java.net.Socket; import java.security.KeyStore; import java.security.SecureRandom; import javax.net.ssl.*; public class SSLServer extends Thread { SSLContext stx; //SSL上下文 SSLServerSocketFactory ssf; //SSL 服务器套接字工厂 SSLServerSocket ssk; //SSL 服务器套接字 SSLSocket sk; //SSL 套接字 KeyManagerFactory kmf; //基于密钥内容源的密钥管理器的工厂 TrustManagerFactory tmf; //基于信任材料源的信任管理器的工厂 BufferedReader in; //缓冲读入流 String kpass="000000"; //密钥密码 String tpass="111111"; //受信任证书密码 public static final String path="D://liuwenwei//chat//ssl//证书//kserver.keystore"; public static final String tpath="D://liuwenwei//chat//ssl//证书//tserver.keystore"; public static final int port=8888; //连接端口号 public SSLServer()throws Exception{ init(); } /** *初始化服务器 *加载并初始化SSL上下文 */ public void init()throws Exception{ //初始化上下文 stx=SSLContext.getInstance("TLS"); System.out.println(stx.getProvider().toString()); kmf=KeyManagerFactory.getInstance("SunX509"); tmf=TrustManagerFactory.getInstance("SunX509"); KeyStore ks=KeyStore.getInstance("JKS"); KeyStore tks=KeyStore.getInstance("JKS"); //加载keystore ks.load(new FileInputStream(path),kpass.toCharArray()); tks.load(new FileInputStream(tpath),tpass.toCharArray()); kmf.init(ks,kpass.toCharArray()); tmf.init(tks); stx.init(kmf.getKeyManagers(),tmf.getTrustManagers(),null); ssf=(SSLServerSocketFactory)stx.getServerSocketFactory(); ssk=(SSLServerSocket)ssf.createServerSocket(port); ssk.setNeedClientAuth(true); this.start(); } public void run(){ String data; String inData; try{ System.out.println("等待连接........"); sk=(SSLSocket)ssk.accept(); System.out.println("连接成功!"); new ReceiveMessage(sk,"服务器"); new SendMessage(sk,"服务器"); }catch(IOException e){ System.out.println("ioexception"); } } public static void main(String[] args)throws Exception{ new SSLServer(); } }