java ssl 双向zz

public class Server implements Runnable{    
   
    private static final int     DEFAULT_PORT                     = 7777;    
   
    private static final String SERVER_KEY_STORE_PASSWORD        = "123456";    
    private static final String SERVER_TRUST_KEY_STORE_PASSWORD = "123456";    
   
    private SSLServerSocket      serverSocket;    
   
    /** 
      * 启动程序 
      * 
      * @param args 
      */   
    public static void main(String[] args) {    
         Server server = new Server();    
         server.init();    
         Thread thread = new Thread(server);    
         thread.start();    
     }    
   
    public synchronized void start() {    
        if (serverSocket == null) {    
             System.out.println("ERROR");    
            return;    
         }    
        while (true) {    
            try {    
                 Socket s = serverSocket.accept();    
                 InputStream input = s.getInputStream();    
                 OutputStream output = s.getOutputStream();    
   
                 BufferedInputStream bis = new BufferedInputStream(input);    
                 BufferedOutputStream bos = new BufferedOutputStream(output);    
   
                byte[] buffer = new byte[20];    
                 bis.read(buffer);    
                 System.out.println("------receive:--------"+new String(buffer).toString());    
   
                 bos.write("yes".getBytes());    
                 bos.flush();    
   
                 s.close();    
             } catch (Exception e) {    
                 System.out.println(e);    
             }    
         }    
     }    
    public void init() {    
        try {    
             SSLContext ctx = SSLContext.getInstance("SSL");    
   
             KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");    
             TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");    
   
             KeyStore ks = KeyStore.getInstance("JKS");    
             KeyStore tks = KeyStore.getInstance("JKS");    
   
             ks.load(new FileInputStream("src/ssl/kserver.keystore"), SERVER_KEY_STORE_PASSWORD.toCharArray());    
             tks.load(new FileInputStream("src/ssl/tserver.keystore"), SERVER_TRUST_KEY_STORE_PASSWORD.toCharArray());    
   
             kmf.init(ks, SERVER_KEY_STORE_PASSWORD.toCharArray());    
             tmf.init(tks);    
   
             ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);    
   
             serverSocket = (SSLServerSocket) ctx.getServerSocketFactory().createServerSocket(DEFAULT_PORT);    
             serverSocket.setNeedClientAuth(true);    
         } catch (Exception e) {    
             System.out.println(e);    
         }    
     }    
   
    public void run() {    
        // TODO Auto-generated method stub    
         start();    
     }    
}

package ssl;    
   
import java.io.BufferedInputStream;    
import java.io.BufferedOutputStream;    
import java.io.FileInputStream;    
import java.io.IOException;    
import java.io.InputStream;    
import java.io.OutputStream;    
import java.security.KeyStore;    
   
import javax.net.ssl.KeyManagerFactory;    
import javax.net.ssl.SSLContext;    
import javax.net.ssl.SSLSocket;    
import javax.net.ssl.TrustManagerFactory;    
   
/** 
* SSL Client 
* 
* @author Leo 
*/   
public class Client {    
   
    private static final String DEFAULT_HOST                     = "127.0.0.1";    
    private static final int     DEFAULT_PORT                     = 7777;    
   
    private static final String CLIENT_KEY_STORE_PASSWORD        = "123456";    
    private static final String CLIENT_TRUST_KEY_STORE_PASSWORD = "123456";    
   
    private SSLSocket            sslSocket;    
   
    /** 
      * 启动客户端程序 
      * 
      * @param args 
      */   
    public static void main(String[] args) {    
        Client client = new Client();    
         client.init();    
         client.process();    
     }    
   
   
    public void process() {    
        if (sslSocket == null) {    
             System.out.println("ERROR");    
            return;    
         }    
        try {    
             InputStream input = sslSocket.getInputStream();    
             OutputStream output = sslSocket.getOutputStream();    
   
             BufferedInputStream bis = new BufferedInputStream(input);    
             BufferedOutputStream bos = new BufferedOutputStream(output);    
   
             bos.write("1234567890".getBytes());    
             bos.flush();    
   
            byte[] buffer = new byte[20];    
             bis.read(buffer);    
             System.out.println(new String(buffer));    
   
             sslSocket.close();    
         } catch (IOException e) {    
             System.out.println(e);    
         }    
     }    
   
   
    public void init() {    
        try {    
             SSLContext ctx = SSLContext.getInstance("SSL");    
   
             KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");    
             TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");    
   
             KeyStore ks = KeyStore.getInstance("JKS");    
             KeyStore tks = KeyStore.getInstance("JKS");    
   
             ks.load(new FileInputStream("src/ssl/kclient.keystore"), CLIENT_KEY_STORE_PASSWORD.toCharArray());    
             tks.load(new FileInputStream("src/ssl/tclient.keystore"), CLIENT_TRUST_KEY_STORE_PASSWORD.toCharArray());    
   
             kmf.init(ks, CLIENT_KEY_STORE_PASSWORD.toCharArray());    
             tmf.init(tks);    
   
             ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);    
   
             sslSocket = (SSLSocket) ctx.getSocketFactory().createSocket(DEFAULT_HOST, DEFAULT_PORT);    
         } catch (Exception e) {    
             System.out.println(e);    
         }    
     }    
   
}