Android OpenSSL实例（调试通过）

import java.io.BufferedOutputStream; import java.io.BufferedReader; import java.io.ByteArrayOutputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.PrintStream; import java.security.KeyPair; import java.security.KeyStore; import java.security.MessageDigest; import java.security.PrivateKey; import java.security.PublicKey; import java.security.Signature; import java.text.DateFormat; import java.util.Date; import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLServerSocket; import javax.net.ssl.SSLServerSocketFactory; import javax.net.ssl.SSLSocket; public class AndroidSSLServer2 implements Runnable, Cloneable { private static final int SERVER_PORT = 6666; //端口号 private static final String SERVER_IP = "192.168.2.148"; //"127.0.0.1";//连接IP private static final String SERVER_KEYSTORE_PASSWORD = "1234567"; //私钥密码 private static final String SERVER_TRUSTSTORE_PASSWORD = "1234567";//信任证书密码 private static final String SERVER_AGREEMENT = "TLS"; //使用协议 private static final String SERVER_KEY_MANAGER = "X509"; //密钥管理器 private static final String SERVER_TRUST_MANAGER = "X509"; //信任证书管理器 private static final String SERVER_KEYSTORE_TYPE = "BKS"; //"JKS";//密库，这里用的是BouncyCastle密库 private static final String SERVER_TRUSTSTORE_TYPE = "BKS"; //"JKS";// private static final String ENCONDING = "utf-8"; //字符集 private static final String KEYSTORE = "..\\data\\server.keystore.bks"; public SSLSocket client; public PrintStream out; public InputStream in; private Thread serverInstance; private SSLServerSocket serverSocket; private int port; public AndroidSSLServer2() { client = null; } public boolean clientIsOpen() { return client != null; } public Object clone() { try { return super.clone(); } catch(CloneNotSupportedException _ex) { throw new InternalError(); } } public void close() throws IOException { client.close(); client = null; in = null; out = null; } public static void main(String args[]) { // System.setProperty("javax.net.ssl.trustStore","MyCacertsFile"); // Security.addProvider(new org.bouncycastle.jce.provider.BouncyCastleProvider()); // Security.setProperty(arg0, arg1) try { (new AndroidSSLServer2()).startServer(); System.out.println("Server started at port: " + SERVER_PORT); } catch(IOException ioexception) { System.out.print("Server failed: " + ioexception + "\n"); } } public final void run() { if(serverSocket != null) { // Thread.currentThread().setPriority(10); try { do { SSLSocket socket = (SSLSocket)serverSocket.accept(); AndroidSSLServer2 networkserver = (AndroidSSLServer2)clone(); networkserver.serverSocket = null; networkserver.client = socket; (new Thread(networkserver)).start(); System.out.println("new Thread: networkserver == " + networkserver + ", and start it."); } while(true); } catch(Exception exception) { System.out.print("Server failure\n"); exception.printStackTrace(); } try { serverSocket.close(); } catch(IOException exception) { } System.out.print("cs=" + serverSocket + "\n"); } else { try { out = new PrintStream(new BufferedOutputStream(client.getOutputStream()), false); BufferedReader inOfClient = new BufferedReader( new InputStreamReader( client.getInputStream()), 8192); while (true) { StringBuffer str = new StringBuffer(""); String line = null; // while((line = inOfClient.readLine()) != null) { //// if (!inOfClient.ready()) { //// break; //// } // str.append(line); // System.out.println("line == " + line); // } str.append(inOfClient.readLine()); if (str.toString().equals("")) { str.append("0"); } System.out.println("str: " + str.toString()); int operation = 0; if (String.valueOf(1).equalsIgnoreCase(str.toString())) { operation = 1; } else if (String.valueOf(2).equalsIgnoreCase(str.toString())) { operation = 2; } System.out.println("operation: " + operation); // int operation = 0; // String str = ""; switch(operation) { case 1://客户建立连接 connectedToClient(); break; case 2://客户需要关闭 close(); return; default: serviceRequest(str.toString()); break; } } } catch(Exception exception) { exception.printStackTrace(); } } } private boolean connectedToClient() { System.out.println("-------------------Server connected to client: start--------------------------"); System.out.println("Connected!"); out.println("Connected!\n"); out.println(); out.flush(); System.out.println("-------------------Server connected to client: end--------------------------"); return true; } public void serviceRequest(String string) throws IOException { String date = DateFormat.getInstance().format(new Date()); System.out.println("-------------------The messages server sending to client: start--------------------------"); System.out.println("I am server. The message you sent to me is: " + string+". "); System.out.println("The data following is printed from server:\n"); System.out.println("HTTP/1.0 200 OK\n"); System.out.println("Hello, this is a SSL Time server: " + getClass().getName() + ", Port: " + this.port+"\n"); System.out.println("Current time:" + date); // System.out.println();//shenbo//对传输的数据进行数字签名 System.out.println("over!\n"); System.out.println("-------------------The messages server sending to client: end--------------------------"); // out.print("I am server. The message you sent to me is: " + string); // out.println("The data following is printed from server:\n"); out.println("HTTP/1.0 200 OK\n"); out.println("Hello, this is a SSL Time server: " + getClass().getName() + ", Port: " + this.port+"\n"); out.println("Current time:" + date + "\n"); // out.println();//shenbo//对传输的数据进行数字签名 out.println("over!\n"); out.flush(); } public final void startServer() throws IOException { port = SERVER_PORT;