在Java Socket中实现数据的加密传输，可以使用Java的加密扩展（Java Cryptography Extension，JCE）和Java Secure Socket Extension（JSSE）。以下是一个简单的示例，展示了如何使用SSL/TLS协议在客户端和服务器之间进行加密通信。
首先，生成一个自签名证书，用于服务器和客户端之间的身份验证和加密通信。在命令行中运行以下命令：keytool -genkeypair -alias mykeystore -keyalg RSA -keysize 2048 -keystore mykeystore.jks -validity 3650这将生成一个名为mykeystore.jks的Java密钥库文件。
import javax.net.ssl.*;import java.io.*;public class SecureServer { public static void main(String[] args) throws Exception { // Load the keystore KeyStore ks = KeyStore.getInstance("JKS"); ks.load(new FileInputStream("mykeystore.jks"), "password".toCharArray()); // Set up the key manager factory KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509"); kmf.init(ks, "password".toCharArray()); // Set up the trust manager factory TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509"); tmf.init(ks); // Create the SSL context SSLContext sslContext = SSLContext.getInstance("TLS"); sslContext.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null); // Create the SSL server socket SSLServerSocketFactory sslServerSocketFactory = sslContext.getServerSocketFactory(); SSLServerSocket sslServerSocket = (SSLServerSocket) sslServerSocketFactory.createServerSocket(8080); // Accept client connections SSLSocket sslSocket = (SSLSocket) sslServerSocket.accept(); // Read data from the client InputStream inputStream = sslSocket.getInputStream(); BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream)); String line; while ((line = reader.readLine()) != null) { System.out.println("Received: " + line); } // Close the connection sslSocket.close(); sslServerSocket.close(); }}import javax.net.ssl.*;import java.io.*;public class SecureClient { public static void main(String[] args) throws Exception { // Load the keystore KeyStore ks = KeyStore.getInstance("JKS"); ks.load(new FileInputStream("mykeystore.jks"), "password".toCharArray()); // Set up the key manager factory KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509"); kmf.init(ks, "password".toCharArray()); // Set up the trust manager factory TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509"); tmf.init(ks); // Create the SSL context SSLContext sslContext = SSLContext.getInstance("TLS"); sslContext.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null); // Create the SSL socket SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory(); SSLSocket sslSocket = (SSLSocket) sslSocketFactory.createSocket("localhost", 8080); // Send data to the server OutputStream outputStream = sslSocket.getOutputStream(); PrintWriter writer = new PrintWriter(outputStream, true); writer.println("Hello, secure server!"); // Close the connection sslSocket.close(); }}现在，当你运行SecureServer和SecureClient时，它们将通过SSL/TLS协议进行加密通信。请注意，这个示例使用了自签名证书，因此在实际生产环境中，你需要使用由受信任的证书颁发机构（CA）签发的证书。
