关于java:Android-Socket与HTTPS校验

39次阅读

共计 13059 个字符，预计需要花费 33 分钟才能阅读完成。

在 Android 中应用 HTTPS 的场景比拟频繁，所以对于 HTTPS 的证书应该如何校验呢？对于 HTTPS 的校验原理能够参考我之前写的一篇文章：《HTTPS 协定实现原理》，置信看完后应该对 HTTPS 有一个比拟大抵的理解。而且对 HTTP(s) 申请的工具进行了封装，须要领会这种封装工具类的思路，也就是编码中常见的 Listener 机制。而后是 Android 中 TCP、UDP 通信的例子，次要是把 Android 设施作为 Client 端，如果对 Java 的 Socket 编程比拟相熟的话，这些都是特地简略的示例程序，非常容易看懂。

<!– more –>

TCP/UDP 简略示例

上面的例子演示了 Client 向 Server 发送了一串小写英文，Server 返回大写字符串的性能：

UDPServer.java：

public class UDPServer {private static final SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");
    public static void main(String[] args) throws Exception {
        DatagramSocket datagramSocket;
        datagramSocket = new DatagramSocket(8090);
        byte[] buf;
        DatagramPacket packet;
        while (true){buf = new byte[1024];
            packet = new DatagramPacket(buf, buf.length);
            datagramSocket.receive(packet);
            String content = new String(packet.getData());
            InetAddress address = packet.getAddress();
            System.out.println(format.format(new Date()) + "-" + address + "-" + content);
            int port = packet.getPort();
            String replyContent = content.toUpperCase();
            byte[] sendData = replyContent.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, address, port);
            datagramSocket.send(sendPacket);
        }
    }
}

UDPClient.java：

public class UDPClient {private static final SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");
    public static void main(String[] args) throws Exception {System.out.println("请输出一句英文，服务器会返回其大写模式 [exit 退出]");
        Scanner scanner = new Scanner(System.in);
        InetAddress address = InetAddress.getLocalHost();
        DatagramPacket packet;
        DatagramSocket socket = new DatagramSocket();
        while(true){String line = scanner.nextLine();
            if("exit".equals(line)) break;
            byte[] bytes = line.getBytes();
            packet = new DatagramPacket(bytes, bytes.length, address, 8090);
            socket.send(packet);
            byte[] recvBuf = new byte[1024];
            DatagramPacket recvPacket = new DatagramPacket(recvBuf, recvBuf.length);
            socket.receive(recvPacket);
            System.out.println(format.format(new Date()) + "-" + address + "-" + new String(recvBuf));
        }
        socket.close();}
}

TCPServer.java：

public class TCPServer {static SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");
    public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(9090);
        while (true){Socket socket = serverSocket.accept();
            InetAddress address = socket.getInetAddress();
            InputStream is = socket.getInputStream();
            byte[] readBuf = new byte[1024];
            try{int len = is.read(readBuf);
                String recv = new String(readBuf, 0, len);
                System.out.println(format.format(new Date()) + "-" + address + "-" + recv);
                OutputStream os = socket.getOutputStream();
                os.write(recv.toUpperCase().getBytes());
            } catch (SocketException e){System.err.println("客户端未发送信息");
            } finally {socket.close();
            }
        }
    }
}

TCPClient.java：

public class TCPClient {private static final SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");
    public static void main(String[] args) throws Exception {System.out.println("请输出一句英文，服务器会返回其大写模式 [exit 退出]");
        Scanner scanner = new Scanner(System.in);
        while(true){Socket socket = new Socket("127.0.0.1", 9090);
            String line = scanner.nextLine();
            if("exit".equals(line)) break;
            OutputStream os = socket.getOutputStream();
            os.write(line.getBytes());
            InputStream is = socket.getInputStream();
            byte[] readBuf = new byte[1024];
            String recv = new String(readBuf, 0, is.read(readBuf));
            InetAddress address = socket.getInetAddress();
            System.out.println(format.format(new Date()) + "-" + address + "-" + recv);
            socket.close();}
    }
}

Client 移植到 Android

将两个 Client 移植到 Android：

activity_main.xml

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical"
    android:padding="10dp"
    tools:context=".MainActivity">

    <EditText
        android:hint="输出发送内容"
        android:id="@+id/et_content"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"/>

    <LinearLayout
        android:orientation="horizontal"
        android:layout_width="match_parent"
        android:layout_height="wrap_content">
        <EditText
            android:text="192.168.1.113:8090"
            android:id="@+id/et_udp_server"
            android:layout_width="0dp"
            android:layout_weight="1"
            android:layout_height="wrap_content">
        </EditText>
        <Button
            android:text="UDP 发送"
            android:onClick="sendUdpMessage"
            android:layout_weight="1"
            android:layout_width="0dp"
            android:layout_height="wrap_content"/>
    </LinearLayout>
    <LinearLayout
        android:orientation="horizontal"
        android:layout_width="match_parent"
        android:layout_height="wrap_content">
        <EditText
            android:text="192.168.1.113:9090"
            android:id="@+id/et_tcp_server"
            android:layout_width="0dp"
            android:layout_weight="1"
            android:layout_height="wrap_content">
        </EditText>
        <Button
            android:text="TCP 发送"
            android:onClick="sendTcpMessage"
            android:layout_weight="1"
            android:layout_width="0dp"
            android:layout_height="wrap_content"/>
    </LinearLayout>
    <TextView
        android:id="@+id/tv_show"
        android:text="收到回复："
        android:layout_width="match_parent"
        android:layout_height="wrap_content"/>
</LinearLayout>

MainActivity.java：

public class MainActivity extends AppCompatActivity {
    private static final String TAG = "MainActivity";
    private static final SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss", Locale.CHINA);
    private EditText etInput;
    private TextView textView;
    private EditText udpServerET;
    private EditText tcpServerET;

    @Override
    protected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        etInput = findViewById(R.id.et_content);
        textView = findViewById(R.id.tv_show);
        udpServerET = findViewById(R.id.et_udp_server);
        tcpServerET = findViewById(R.id.et_tcp_server);
    }

    public void sendTcpMessage(View view) {String[] tcpInfo = tcpServerET.getText().toString().split(":");
        String inputContent = etInput.getText().toString();
        new Thread(()->{try (Socket socket = new Socket(tcpInfo[0], Integer.parseInt(tcpInfo[1]))){OutputStream os = socket.getOutputStream();
                os.write(inputContent.getBytes());
                InputStream is = socket.getInputStream();
                byte[] readBuf = new byte[1024];
                String recv = new String(readBuf, 0, is.read(readBuf));
                InetAddress address = socket.getInetAddress();
                String ret = String.format("%s-%s-%s", df.format(new Date()), address, recv);
                runOnUiThread(()-> textView.setText(ret));
            }catch (IOException e){Log.e(TAG, "sendTcpMessage: Error!");
            }
        }).start();}

    public void sendUdpMessage(View view) {String[] udpInfo = udpServerET.getText().toString().split(":");
        String inputContent = etInput.getText().toString();
        new Thread(()->{
            try {DatagramSocket socket = new DatagramSocket();
                byte[] bytes = inputContent.getBytes();
                InetAddress address = InetAddress.getByName(udpInfo[0]);
                int serverPort = Integer.parseInt(udpInfo[1]);
                DatagramPacket packet = new DatagramPacket(bytes, bytes.length, address, serverPort);
                socket.send(packet);
                byte[] recvBuf = new byte[1024];
                DatagramPacket recvPacket = new DatagramPacket(recvBuf, recvBuf.length);
                socket.receive(recvPacket);
                String ret = String.format("%s-%s-%s", df.format(new Date()), address, new String(recvBuf));
                runOnUiThread(()-> textView.setText(ret));
            }catch (IOException e){Log.e(TAG, "sendUdpMessage: Error!");
            }
        }).start();}
}

AndroidManifest.xml：

<uses-permission android:name="android.permission.INTERNET"/>

留神点：1、网络拜访权限 2、子线程代码中应用 runOnUiThread() 办法可更新 UI

Android 拜访 HTTPS

对于一个一般的 HTTP 申请，咱们能够应用如下形式来发动申请，上面是一个繁难的 Http 申请工具类：

public class HttpUtils {private static Handler mUIHandler = new Handler(Looper.getMainLooper());

    interface HttpListener {void onSuccess(String content);

        void onFail(Exception e);
    }

    public static void doGet(String urlStr, HttpListener listener) {new Thread(() -> {Looper.prepare();
            try {URL url = new URL(urlStr);
                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
                conn.setRequestMethod("GET");
                conn.setConnectTimeout(5000);
                conn.setReadTimeout(5000);
                conn.connect();

                try (InputStream is = conn.getInputStream();
                     InputStreamReader reader = new InputStreamReader(is)
                ) {char[] buf = new char[4096];
                    int len;
                    StringBuilder sb = new StringBuilder();
                    while ((len = reader.read(buf)) != -1) {sb.append(new String(buf, 0, len));
                    }
                    mUIHandler.post(() -> listener.onSuccess(sb.toString()));
                } catch (IOException e) {e.printStackTrace();
                    listener.onFail(e);
                }
            }catch (IOException e){e.printStackTrace();
                listener.onFail(e);
            }
        }).start();}
}

1、不校验证书（不举荐）

MyX509TrustManager.java，MyX509TrustManager 实现不做任何事件：

...
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;

import javax.net.ssl.X509TrustManager;

public class MyX509TrustManager implements X509TrustManager {

    @Override
    public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {// TODO...}

    @Override
    public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {// TODO...}

    @Override
    public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[0];
    }
}

HttpsUtils.java

...
public class HttpsUtils {private static Handler mUIHandler = new Handler(Looper.getMainLooper());

    interface HttpListener {void onSuccess(String content);

        void onFail(Exception e);
    }

    public static void doGet(Context context, String urlStr, HttpListener listener) {new Thread(() -> {Looper.prepare();
            try {URL url = new URL(urlStr);
                HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
                SSLContext sslContext = SSLContext.getInstance("TLS");
                // 放入自定义的 MyX509TrustManager 对象即可
                TrustManager[] trustManagers = {new MyX509TrustManager()};
                sslContext.init(null, trustManagers, new SecureRandom());
                conn.setSSLSocketFactory(sslContext.getSocketFactory());
                conn.setRequestMethod("GET");
                conn.setConnectTimeout(5000);
                conn.setReadTimeout(5000);
                conn.connect();

                try (InputStream is = conn.getInputStream();
                     InputStreamReader reader = new InputStreamReader(is)
                ) {char[] buf = new char[4096];
                    int len;
                    StringBuilder sb = new StringBuilder();
                    while ((len = reader.read(buf)) != -1) {sb.append(new String(buf, 0, len));
                    }
                    mUIHandler.post(() -> listener.onSuccess(sb.toString()));
                } catch (IOException e) {e.printStackTrace();
                    listener.onFail(e);
                }
            }catch (Exception e){e.printStackTrace();
                listener.onFail(e);
            }
        }).start();}
}

2、校验证书（举荐）

拿我本人的博客站点来说，想要取得证书只须要在浏览器下载对应的证书即可（抉择 DER 编码二进制和 Base64 编码均可），保留了一个名为 srca.cer 的文件到桌面：

将这份证书文件复制到我的项目的 src/main/assets/ 目录下，没有 assets 就新建，所以残缺门路为 src/main/assets/srca.cer。

接下来须要实现 MyX509TrustManager.java 中的办法：

public class MyX509TrustManager implements X509TrustManager {
    private static final String TAG = "MyX509TrustManager";
    // 证书对象
    private X509Certificate serverCert;

    public MyX509TrustManager(X509Certificate serverCert) {this.serverCert = serverCert;}

    @Override
    public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { }

    @Override
    public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
        // 遍历证书
        for (X509Certificate certificate: chain){
            // 校验合法性与是否过期
            certificate.checkValidity();
            try {
                // 校验公钥
                PublicKey publicKey = serverCert.getPublicKey();
                certificate.verify(publicKey);
            } catch (Exception e) {throw new CertificateException(e);
            }
        }
    }

    @Override
    public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[0];
    }
}

同时，将应用 keyStore 这个 API 来获取 TrustManager 数组，HttpsUtils.java 如下：

public class Https2Utils {private static Handler mUIHandler = new Handler(Looper.getMainLooper());

    interface HttpListener {void onSuccess(String content);

        void onFail(Exception e);
    }

    public static void doGet(Context context, String urlStr, HttpListener listener) {new Thread(() -> {Looper.prepare();
            try {URL url = new URL(urlStr);
                HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
                SSLContext sslContext = SSLContext.getInstance("TLS");
                X509Certificate serverCert = getCert(context);
                String defaultType = KeyStore.getDefaultType();
                KeyStore keyStore = KeyStore.getInstance(defaultType);
                keyStore.load(null);
                // 别名、证书
                keyStore.setCertificateEntry("srca", serverCert);
                String algorithm = TrustManagerFactory.getDefaultAlgorithm();
                TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(algorithm);
                trustManagerFactory.init(keyStore);
                TrustManager[] trustManagers = trustManagerFactory.getTrustManagers();
                sslContext.init(null, trustManagers, new SecureRandom());
                conn.setSSLSocketFactory(sslContext.getSocketFactory());
                // 校验域名是否非法
                conn.setHostnameVerifier((hostname, session) -> {HostnameVerifier verifier = HttpsURLConnection.getDefaultHostnameVerifier();
                    return verifier.verify("zouchanglin.cn", session);
                });
                conn.setRequestMethod("GET");
                conn.setConnectTimeout(5000);
                conn.setReadTimeout(5000);
                conn.connect();

                try (InputStream is = conn.getInputStream();
                     InputStreamReader reader = new InputStreamReader(is)
                ) {char[] buf = new char[4096];
                    int len;
                    StringBuilder sb = new StringBuilder();
                    while ((len = reader.read(buf)) != -1) {sb.append(new String(buf, 0, len));
                    }
                    mUIHandler.post(() -> listener.onSuccess(sb.toString()));
                } catch (IOException e) {e.printStackTrace();
                    listener.onFail(e);
                }
            }catch (Exception e){e.printStackTrace();
                listener.onFail(e);
            }
        }).start();}

    private static X509Certificate getCert(Context context) {
        try {
            // src/main/assets/srca.cer
            InputStream inputStream = context.getAssets().open("srca.cer");
            CertificateFactory factory = CertificateFactory.getInstance("X.509");
            return (X509Certificate) factory.generateCertificate(inputStream);
        } catch (IOException | CertificateException e) {e.printStackTrace();
        }
        return null;
    }
}

在 MainActivity 中应用也很简略：

public class MainActivity extends AppCompatActivity {

    private EditText etUrl;
    private TextView tvShow;

    @Override
    protected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        etUrl = findViewById(R.id.et_url);
        tvShow = findViewById(R.id.tv_show);
    }

    public void loadContent(View view) {String url = etUrl.getText().toString();
        Https2Utils.doGet(this, url, new Https2Utils.HttpListener() {
            @Override
            public void onSuccess(String content) {tvShow.setText(content);
            }

            @Override
            public void onFail(Exception e) {Toast.makeText(MainActivity.this, "Failed！", Toast.LENGTH_SHORT).show();}
        });
    }
}

原文地址《Android Socket 与 HTTPS 校验》

正文完
java
发表至： java
2020-12-11
 0
关于java:别再写满屏的-get-set-了太-Low试试-MapStruct-高级玩法
关于微信支付:手把手教你接入微信支付
数据结构与算法平衡二叉树和红黑树
关于java:Redis-面试常见问题缓存雪崩缓存击穿以及缓存穿透