深海游弋的鱼 – 智障儿童欢乐多

Android页面内嵌入FlutterView

随着Flutter的流行，越来越多的开发者希望在现有的Android应用中引入Flutter的功能。本文将介绍如何在Android应用中嵌入Flutter View，并提供示例代码来帮助开发者快速上手。

1. 环境准备

在开始之前，请确保您已安装以下工具：

Android Studio
Flutter SDK

首先，您需要在您的Android应用中添加Flutter依赖。在build.gradle文件中添加Flutter相关的依赖：

dependencies {
    implementation 'io.flutter:flutter_embedding_debug:1.0.0' // 请根据具体版本调整
}

dependencies {

implementation 'io.flutter:flutter_embedding_debug:1.0.0' // 请根据具体版本调整

}

2. 创建Flutter Module

接下来，您需要创建一个Flutter模块。在命令行中运行以下命令：

flutter create -t module flutter_module

1	flutter create -t module flutter_module

这将创建一个名为flutter_module的Flutter模块。

3. 在Android中集成Flutter

3.1 修改Android原生代码

在您的Android项目中，首先需要设置Flutter引擎。在主活动的onCreate方法中，您可以添加如下代码来初始化Flutter：

import io.flutter.embedding.android.FlutterActivity;
import io.flutter.embedding.engine.FlutterEngine;
import io.flutter.plugin.common.MethodChannel;

public class MainActivity extends AppCompatActivity {
    private static final String CHANNEL = "com.example.channel";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        // Initialize Flutter Engine
        FlutterEngine flutterEngine = new FlutterEngine(this);
        flutterEngine.getDartExecutor().executeDartEntrypoint(
            DartExecutor.DartEntrypoint.createDefault()
        );

        // Set up MethodChannel to communicate between Android and Flutter
        new MethodChannel(flutterEngine.getDartExecutor().getBinaryMessenger(), CHANNEL)
            .setMethodCallHandler((call, result) -> {
                // Handle method calls from Flutter here
            });

        // Start FlutterActivity
        FlutterActivity.withCachedEngine("my_engine_id")
            .startActivity(this);
    }
}

import io.flutter.embedding.android.FlutterActivity;

import io.flutter.embedding.engine.FlutterEngine;

import io.flutter.plugin.common.MethodChannel;

public class MainActivity extends AppCompatActivity {

private static final String CHANNEL = "com.example.channel";

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

// Initialize Flutter Engine

FlutterEngine flutterEngine = new FlutterEngine(this);

flutterEngine.getDartExecutor().executeDartEntrypoint(

DartExecutor.DartEntrypoint.createDefault()

);

// Set up MethodChannel to communicate between Android and Flutter

new MethodChannel(flutterEngine.getDartExecutor().getBinaryMessenger(), CHANNEL)

.setMethodCallHandler((call, result) -> {

// Handle method calls from Flutter here

});

// Start FlutterActivity

FlutterActivity.withCachedEngine("my_engine_id")

.startActivity(this);

}

3.2 在XML布局中添加FlutterView

接下来，您可以在XML布局中添加FlutterView。这里是一个示例布局：

<RelativeLayout xmlns:android="
    android:layout_width="match_parent"
    android:layout_height="match_parent">

    <io.flutter.embedding.android.FlutterView
        android:id="@+id/flutter_view"
        android:layout_width="match_parent"
        android:layout_height="match_parent" />
</RelativeLayout>

<RelativeLayout xmlns:android="

android:layout_width="match_parent"

android:layout_height="match_parent">

<io.flutter.embedding.android.FlutterView

android:id="@+id/flutter_view"

android:layout_width="match_parent"

android:layout_height="match_parent" />

</RelativeLayout>

3.3 Flutter View的显示

在设置好布局后，您需要在Java代码中加载FlutterView并显示它：

FlutterView flutterView = findViewById(R.id.flutter_view);
flutterView.attachToFlutterEngine(flutterEngine);

1 2	FlutterView flutterView = findViewById(R.id.flutter_view); flutterView.attachToFlutterEngine(flutterEngine);

3.4 生命周期绑定

在 Android Acvitity 的生命周期中调用 appIsResumed()、appIsInactive、appIsPaused、appIsDetached以通知flutter界面进入相应状态，否则页面会出现绘制异常。

@Override
protected void onResume() {
    super.onResume();
    /*...dosomething*/
    getEngine().getLifecycleChannel().appIsResumed();
}

@Override
protected void onPause() {
    super.onPause();
    /*...dosomething*/
    getEngine().getLifecycleChannel().appIsInactive();
}

@Override
protected void onDestroy() {
    super.onDestroy();
    /*...dosomething*/
    getEngine().getLifecycleChannel().appIsDetached();
}

@Override

protected void onResume() {

super.onResume();

/*...dosomething*/

getEngine().getLifecycleChannel().appIsResumed();

}

@Override

protected void onPause() {

super.onPause();

/*...dosomething*/

getEngine().getLifecycleChannel().appIsInactive();

}

@Override

protected void onDestroy() {

super.onDestroy();

/*...dosomething*/

getEngine().getLifecycleChannel().appIsDetached();

}

参考链接

mbedtls tls 客户端应用详解

介绍 mbedtls 的 tls client 的使用方法，常见的功能参数配置和含义。当前使用的 mbedtls 版本是： mbedtls-3.4.0。

功能参数配置

需要配置的功能选项

设置 tls 协议版本: 配置 tls 1.2, tls 1.3, 还是二者都支持。
认证方式设置：单向认证、双向认证、还是 psk。
握手时的校验等级设置：不校验证书合法性，仅加密；校验，但如果失败也继续执行后面的握手流程；校验不通过则终止握手流程。
服务器ca证书设置
客户端证书和密钥设置
预定义共享密钥设置

编译配置

使用 mbedtls_config.h 配置文件，tls 1.2 默认打开，不需要修改，但 tls 1.3 未开启，需要特别设置。

//mbedtls_config.h 
#define MBEDTLS_SSL_PROTO_TLS1_3
#define MBEDTLS_SSL_TLS1_3_COMPATIBILITY_MODE
#define MBEDTLS_USE_PSA_CRYPTO
#define MBEDTLS_PSA_CRYPTO_CONFIG

//mbedtls_config.h

#define MBEDTLS_SSL_PROTO_TLS1_3

#define MBEDTLS_SSL_TLS1_3_COMPATIBILITY_MODE

#define MBEDTLS_USE_PSA_CRYPTO

#define MBEDTLS_PSA_CRYPTO_CONFIG

解决 mps_common.h 中的编译问题，替换 MBEDTLS_MPS_STORED_SIZE_MAX 和 MBEDTLS_MPS_SIZE_MAX 宏定义。

//mps_common.h
#define MBEDTLS_MPS_STORED_SIZE_MAX  (SIZE_MAX)
#define MBEDTLS_MPS_SIZE_MAX  (SIZE_MAX)

//mps_common.h

#define MBEDTLS_MPS_STORED_SIZE_MAX (SIZE_MAX)

#define MBEDTLS_MPS_SIZE_MAX (SIZE_MAX)

API 设计和实现

接口处理的事情，主要是连接参数配置、打开和关闭连接，接收和发送数据。

数据结构定义：

typedef enum
{
    QTF_TLS_AUTH_MODE_CERT = 0, // 校验证书
    QTF_TLS_AUTH_MODE_PSK, // 预定义共享密钥
    QTF_TLS_AUTH_MODE_MAX
}qtf_tls_auth_mode_t;

typedef enum
{
    QTF_TLS_VERSION_TLS1_2 = 0,     // TLS v1.2
    QTF_TLS_VERSION_TLS1_3,         // TLS v1.3
    QTF_TLS_VERSION_TLS1_2_1_3,     // TLS v1.2 and TLS v1.3
    QTF_TLS_VERSION_MAX
}qtf_tls_version_t;

typedef enum
{
    QTF_TLS_VERIFY_MODE_NONE = 0, // 不校验证书是否合法
    QTF_TLS_VERIFY_MODE_OPTIONAL, // 证书校验失败，继续执行握手
    QTF_TLS_VERIFY_MODE_REQUIRED, // 证书校验失败终止握手，推荐配置
    QTF_TLS_VERIFY_MODE_MAX
}qtf_tls_verify_mode_t;

typedef enum
{
    QTF_TLS_DEBUG_LEVEL_NONE = 0,
    QTF_TLS_DEBUG_LEVEL_ERROR,
    QTF_TLS_DEBUG_LEVEL_STATE,
    QTF_TLS_DEBUG_LEVEL_INFO,
    QTF_TLS_DEBUG_LEVEL_VERBOSE,
}qtf_tls_debug_level_t;

// tls 报文分片大小设置
typedef enum
{
    QTF_TLS_MAX_FRAG_LEN_NO_USE = 0, // 不设置
    QTF_TLS_MAX_FRAG_LEN_512, // 设置 tls 报文分片大小 512 字节
    QTF_TLS_MAX_FRAG_LEN_1024,
    QTF_TLS_MAX_FRAG_LEN_2048,
    QTF_TLS_MAX_FRAG_LEN_4096,
}qtf_tls_max_frag_len_t;

typedef struct
{
    qtf_tls_auth_mode_t auth_mode; // 认证方式
    qtf_tls_verify_mode_t verify_mode; // 握手校验等级
    qtf_tls_version_t tls_version; // tls 协议版本设置
    qtf_tls_debug_level_t debug_level; // 调试日志等级设置
    qtf_tls_max_frag_len_t max_frag_len; // 报文分片大小设置
    uint32_t hanshake_timeout_ms; // 握手超时时间设置
    const char *ca_cert; 	// 服务器ca 证书
    uint32_t ca_cert_len;
    const char *client_cert; // 客户端证书
    uint32_t client_cert_len;
    const char *client_key; // 客户端密钥
    uint32_t client_key_len;
    const char *client_key_passwd;
    uint32_t client_key_passwd_len;
    const char *psk; // 预定义共享密钥
    uint32_t psk_len;
    const char *psk_id;
}qtf_tls_conn_param_t;

typedef enum

{

QTF_TLS_AUTH_MODE_CERT = 0, // 校验证书

QTF_TLS_AUTH_MODE_PSK, // 预定义共享密钥

QTF_TLS_AUTH_MODE_MAX

}qtf_tls_auth_mode_t;

typedef enum

{

QTF_TLS_VERSION_TLS1_2 = 0, // TLS v1.2

QTF_TLS_VERSION_TLS1_3, // TLS v1.3

QTF_TLS_VERSION_TLS1_2_1_3, // TLS v1.2 and TLS v1.3

QTF_TLS_VERSION_MAX

}qtf_tls_version_t;

typedef enum

{

QTF_TLS_VERIFY_MODE_NONE = 0, // 不校验证书是否合法

QTF_TLS_VERIFY_MODE_OPTIONAL, // 证书校验失败，继续执行握手

QTF_TLS_VERIFY_MODE_REQUIRED, // 证书校验失败终止握手，推荐配置

QTF_TLS_VERIFY_MODE_MAX

}qtf_tls_verify_mode_t;

typedef enum

{

QTF_TLS_DEBUG_LEVEL_NONE = 0,

QTF_TLS_DEBUG_LEVEL_ERROR,

QTF_TLS_DEBUG_LEVEL_STATE,

QTF_TLS_DEBUG_LEVEL_INFO,

QTF_TLS_DEBUG_LEVEL_VERBOSE,

}qtf_tls_debug_level_t;

// tls 报文分片大小设置

typedef enum

{

QTF_TLS_MAX_FRAG_LEN_NO_USE = 0, // 不设置

QTF_TLS_MAX_FRAG_LEN_512, // 设置 tls 报文分片大小 512 字节

QTF_TLS_MAX_FRAG_LEN_1024,

QTF_TLS_MAX_FRAG_LEN_2048,

QTF_TLS_MAX_FRAG_LEN_4096,

}qtf_tls_max_frag_len_t;

typedef struct

{

qtf_tls_auth_mode_t auth_mode; // 认证方式

qtf_tls_verify_mode_t verify_mode; // 握手校验等级

qtf_tls_version_t tls_version; // tls 协议版本设置

qtf_tls_debug_level_t debug_level; // 调试日志等级设置

qtf_tls_max_frag_len_t max_frag_len; // 报文分片大小设置

uint32_t hanshake_timeout_ms; // 握手超时时间设置

const char *ca_cert; // 服务器ca 证书

uint32_t ca_cert_len;

const char *client_cert; // 客户端证书

uint32_t client_cert_len;

const char *client_key; // 客户端密钥

uint32_t client_key_len;

const char *client_key_passwd;

uint32_t client_key_passwd_len;

const char *psk; // 预定义共享密钥

uint32_t psk_len;

const char *psk_id;

}qtf_tls_conn_param_t;

连接参数配置说明：

auth_mode：认证方式设置。

一是通过证书认证，另一个是通过预定义密钥 PSK。
verify_mode：握手的校验等级。

推荐配置为 QTF_TLS_VERIFY_MODE_REQUIRED。如果只是想加密而不校验，可以配置 QTF_TLS_VERIFY_MODE_NONE 或 QTF_TLS_VERIFY_MODE_OPTIONAL。
tls_version：tls 协议版本。

推荐配置成 tls 1.2 或 tls 1.3，tls 1.2 以下的版本不安全，tls 1.3 版本 mbedtls 没有完整支持。
debug_level：日志等级。

推荐设置 QTF_TLS_DEBUG_LEVEL_NONE 关闭日志输出。排查问题时可以将日志打开 QTF_TLS_DEBUG_LEVEL_VERBOSE（注意会打印密钥和收发数据的明文内容）。
max_frag_len：数据分片大小设置。

在客户端侧设置，用于协商数据分片大小，设置这个参数应该是出于对使用内存大小和带宽的考虑。

设置太小，可能会出现服务器证书接收不完整导致握手失败问题，但最大值也不能设置超过接收缓冲区的大小。
hanshake_timeout_ms：握手超时时间。
ca_cert：服务器的 ca 证书。

如果要求校验证书，则必须设置。客户端校验服务器是否合法，单向认证。
client_cert：客户端证书。

要求双向认证的时候必须设置，用于服务器校验客户端是否合法。同时还要设置 client_key。
psk ：预定义共享密钥。

psk 不需要证书认证，减少握手数据交互流程，但需要指定 psk_id 身份标识和指定加密套件。

接口定义：

void *qtf_tls_connect(const char *host, uint16_t port, qtf_tls_conn_param_t *param);
int qtf_tls_send(void *handle, const void *buf, uint32_t len, uint32_t timeout_ms);
int qtf_tls_recv(void *handle, void *buf, uint32_t len, uint32_t timeout_ms);
int qtf_tls_close(void *handle);

void *qtf_tls_connect(const char *host, uint16_t port, qtf_tls_conn_param_t *param);

int qtf_tls_send(void *handle, const void *buf, uint32_t len, uint32_t timeout_ms);

int qtf_tls_recv(void *handle, void *buf, uint32_t len, uint32_t timeout_ms);

int qtf_tls_close(void *handle);

接口实现:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "qt_idf_tls.h"
#include "dlg/dlg.h"

#include "mbedtls/net_sockets.h"
#include "mbedtls/ssl.h"
#include "mbedtls/ctr_drbg.h"
#include "mbedtls/debug.h"
#include "mbedtls/platform.h"
#include "mbedtls/timing.h"
#include "mbedtls/entropy.h"
#include "mbedtls/error.h"

typedef struct
{
    mbedtls_net_context      socket_fd;
    mbedtls_entropy_context  entropy;
    mbedtls_ctr_drbg_context ctr_drbg;
    mbedtls_ssl_context      ssl;
    mbedtls_ssl_config       ssl_conf;
    mbedtls_x509_crt         ca_cert;
    mbedtls_x509_crt         client_cert;
    mbedtls_pk_context       private_key;
}qtf_tls_handle_t;

#if defined(MBEDTLS_DEBUG_C)
static void _ssl_debug(void *ctx, int level, const char *file, int line, const char *str)
{
    printf("[mbedTLS]:[%s]:[%d]: %s\r\n", (file), line, (str));
}

#endif

static int _mbedtls_tcp_connect(mbedtls_net_context *ctx, const char *host, uint16_t port)
{
    int ret = 0;
    char port_str[6] = {0};

    snprintf(port_str, sizeof(port_str), "%d", port);

    ret = mbedtls_net_connect(ctx, host, port_str, MBEDTLS_NET_PROTO_TCP);
    if(ret != 0)
    {
        dlg_error("mbedtls_net_connect connect failed returned 0x%04x errno: %d", ret < 0 ? -ret : ret, errno);
       
        return ret;
    }

    ret = mbedtls_net_set_block(ctx);
    if(ret != 0)
    {
        dlg_error("mbedtls_net_set_block failed returned 0x%04x errno: %d", ret < 0 ? -ret : ret, errno);
        return ret;
    }

    return 0;
}

static int _tls_net_init(qtf_tls_handle_t *handle, qtf_tls_conn_param_t *param)
{
    int ret = -1;

    mbedtls_net_init(&(handle->socket_fd));
    mbedtls_ssl_init(&(handle->ssl));
    mbedtls_ssl_config_init(&(handle->ssl_conf));
    mbedtls_ctr_drbg_init(&(handle->ctr_drbg));
    
    mbedtls_entropy_init(&(handle->entropy));

#if defined(MBEDTLS_DEBUG_C)
    mbedtls_debug_set_threshold(param->debug_level);
    mbedtls_ssl_conf_dbg(&handle->ssl_conf, _ssl_debug, NULL);
#endif

#if defined(MBEDTLS_USE_PSA_CRYPTO) || defined(MBEDTLS_SSL_PROTO_TLS1_3)
    // tls 1.3 需要调用 psa_crypto_init
    ret = psa_crypto_init();
    if (ret != PSA_SUCCESS)
    {
        dlg_error("psa_crypto_init failed");
        goto error;
    }
#endif

    ret = mbedtls_ssl_conf_max_frag_len(&(handle->ssl_conf), param->max_frag_len);
    if (ret != 0)
    {
        dlg_error("mbedtls_ssl_conf_max_frag_len failed");
        goto error;
    }


    ret = mbedtls_ctr_drbg_seed(&(handle->ctr_drbg), mbedtls_entropy_func, &(handle->entropy), NULL, 0);
    if (ret != 0)
    {
        dlg_error("mbedtls_ctr_drbg_seed failed");
        goto error;
    }
	
    // 证书认证方式
    if(param->auth_mode == QTF_TLS_AUTH_MODE_CERT)
    {
        if(param->ca_cert && param->ca_cert_len)
        {
            mbedtls_x509_crt_init(&(handle->ca_cert));
            ret = mbedtls_x509_crt_parse(&(handle->ca_cert), (const unsigned char *)param->ca_cert, param->ca_cert_len+1);
            if (ret != 0)
            {
                dlg_error("mbedtls_x509_crt_parse failed");
                goto error;
            }
        }
        else
        {
            if(param->verify_mode != QTF_TLS_VERIFY_MODE_NONE)
            {
                dlg_error("invalid ca cert");
                goto error;
            }
            dlg_info("verify mode is none");
        }
        
        mbedtls_ssl_conf_ca_chain(&(handle->ssl_conf), &(handle->ca_cert), NULL);
		
        if (param->client_cert && param->client_cert_len && param->client_key && param->client_key_len)
        {
            // 双向认证
            mbedtls_x509_crt_init(&(handle->client_cert));
            mbedtls_pk_init(&(handle->private_key));
            ret = mbedtls_x509_crt_parse(&(handle->client_cert), (const unsigned char *)param->client_cert, param->client_cert_len + 1);
            if (ret != 0)
            {
                dlg_error("mbedtls_x509_crt_parse failed");
                goto error;
            }

            ret = mbedtls_pk_parse_key(&(handle->private_key), (const unsigned char *)param->client_key,
                                       param->client_key_len + 1, (const unsigned char *)param->client_key_passwd, param->client_key_passwd_len + 1, NULL, NULL);
            if (ret != 0)
            {
                dlg_error("mbedtls_pk_parse_key failed");
                goto error;
            }
            ret = mbedtls_ssl_conf_own_cert(&(handle->ssl_conf), &(handle->client_cert), &(handle->private_key));
            if (ret != 0)
            {
                dlg_error("mbedtls_ssl_conf_own_cert failed");
                goto error;
            }
        }
    }
    // psk 认证
    else if(param->auth_mode == QTF_TLS_AUTH_MODE_PSK)
    {
        if(param->psk && param->psk_len && param->psk_id)
        {
            ret = mbedtls_ssl_conf_psk(&(handle->ssl_conf), (const unsigned char *)param->psk, param->psk_len,
                                       (const unsigned char *)param->psk_id, strlen(param->psk_id));
            if (ret != 0)
            {
                dlg_error("mbedtls_ssl_conf_psk failed");
                goto error;
            }
        }
        else
        {
            dlg_error("invalid psk");
            goto error;
        }
    }
    else
    {
        dlg_error("invalid auth mode");
        goto error;
    }
    return ret;

error:
    
    return ret;

}

static int __tls_net_deinit(qtf_tls_handle_t *handle)
{
    mbedtls_net_free(&(handle->socket_fd));
    mbedtls_ssl_free(&(handle->ssl));
    mbedtls_ssl_config_free(&(handle->ssl_conf));
    mbedtls_ctr_drbg_free(&(handle->ctr_drbg));
    mbedtls_entropy_free(&(handle->entropy));
    mbedtls_x509_crt_free(&(handle->ca_cert));
    mbedtls_x509_crt_free(&(handle->client_cert));
    mbedtls_pk_free(&(handle->private_key));

    return 0;
}

void *qtf_tls_connect(const char *host, uint16_t port, qtf_tls_conn_param_t *param)
{
    qtf_tls_handle_t *handle = NULL;
    int ret = 0;

    if(!host || !param)
    {
        dlg_error("invalid param");
        goto error;
    }

    handle = (qtf_tls_handle_t *)malloc(sizeof(qtf_tls_handle_t));
    if(!handle)
    {
        dlg_error("malloc failed");
        goto error;
    }
	
    // 配置 tls 连接参数
    ret = _tls_net_init(handle, param);
    if(ret != 0)
    {
        dlg_error("tls net init failed");
        goto error;
    }

    dlg_info("Connecting to %s:%d...", host, port);
	// 建立 tcp 连接
    ret = _mbedtls_tcp_connect(&(handle->socket_fd), host, port);
    if (ret != 0)
    {
        dlg_error("mbedtls_tcp_connect failed");
        goto error;
    }
	
    // 设置 tls 客户端
    mbedtls_ssl_config_defaults(&(handle->ssl_conf), MBEDTLS_SSL_IS_CLIENT, MBEDTLS_SSL_TRANSPORT_STREAM, MBEDTLS_SSL_PRESET_DEFAULT);

    mbedtls_ssl_conf_read_timeout(&(handle->ssl_conf), param->hanshake_timeout_ms);
	
    // 配置认证等级
    mbedtls_ssl_conf_authmode(&(handle->ssl_conf), param->verify_mode);
	
    // 协议版本设置
    if(param->tls_version == QTF_TLS_VERSION_TLS1_2)
    {
        mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);
        mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);
    }
    else if(param->tls_version == QTF_TLS_VERSION_TLS1_3)
    {
        mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);
        mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);
    }
    else
    {
        mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);
        mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);
    }


    mbedtls_ssl_conf_rng(&(handle->ssl_conf), mbedtls_ctr_drbg_random, &(handle->ctr_drbg));

    // todo: config ciphersuites

    ret = mbedtls_ssl_setup(&(handle->ssl), &(handle->ssl_conf));
    if (ret != 0)
    {
        dlg_error("mbedtls_ssl_setup failed");
        goto error;
    }
	
    // 配置 tcp 收发函数，可自定义也可使用 mbedtls 的实现
    mbedtls_ssl_set_bio(&(handle->ssl), &(handle->socket_fd), mbedtls_net_send, mbedtls_net_recv, mbedtls_net_recv_timeout);
	
    // 设置服务器域名，目的是配置 SNI （Server Name Indication） 扩展。
    ret = mbedtls_ssl_set_hostname(&(handle->ssl), host);
    if (ret != 0)
    {
        dlg_error("mbedtls_ssl_set_hostname failed");
        goto error;
    }

    // 执行握手流程
    while ((ret = mbedtls_ssl_handshake(&(handle->ssl))) != 0)
    {
        if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)
        {
            dlg_error("mbedtls_ssl_handshake failed 0x%04x", ret < 0 ? -ret : ret);
            goto error;
        }
    }
	
    // 证书校验结果
    ret = mbedtls_ssl_get_verify_result(&(handle->ssl));
    if (ret < 0)
    {
        dlg_error("mbedtls_ssl_get_verify_result  0x%04x", ret < 0 ? -ret : ret);
        goto error;
    }

    return handle;

error:

    if(handle)
    {
        __tls_net_deinit(handle);
        free(handle);
    }

    return NULL;
}

int qtf_tls_send(void *handle, const void *buf, uint32_t len, uint32_t timeout_ms)
{
    qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;
    int ret = 0;

    if(!handle || !buf || !len)
    {
        dlg_error("invalid param");
        return -1;
    }
	// 发送数据
    while ((ret = mbedtls_ssl_write(&(tls_handle->ssl), (const unsigned char *)buf, len)) <= 0)
    {
        if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)
        {
            dlg_error("mbedtls_ssl_write failed 0x%04x", ret < 0 ? -ret : ret);
            return -1;
        }
    }

    return ret;
}
int qtf_tls_recv(void *handle, void *buf, uint32_t len, uint32_t timeout_ms)
{
    qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;
    int ret = 0;

    if(!handle || !buf || !len)
    {
        dlg_error("invalid param");
        return -1;
    }
	// 接收数据
    while ((ret = mbedtls_ssl_read(&(tls_handle->ssl), (unsigned char *)buf, len)) <= 0)
    {
        if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)
        {
            dlg_error("mbedtls_ssl_read failed 0x%04x", ret < 0 ? -ret : ret);
            return -1;
        }
    }

    return ret;
}

int qtf_tls_close(void *handle)
{
    int ret = 0;
    qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;

    if (!handle)
    {
        dlg_error("invalid param");
        return -1;
    }
	// 关闭连接，释放资源
    do
    {
        ret = mbedtls_ssl_close_notify(&(tls_handle->ssl));
    } while (ret == MBEDTLS_ERR_SSL_WANT_READ || ret == MBEDTLS_ERR_SSL_WANT_WRITE);

    __tls_net_deinit(tls_handle);
    free(tls_handle);

    return 0;
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

374

375

376

377

378

379

380

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include "qt_idf_tls.h"

#include "dlg/dlg.h"

#include "mbedtls/net_sockets.h"

#include "mbedtls/ssl.h"

#include "mbedtls/ctr_drbg.h"

#include "mbedtls/debug.h"

#include "mbedtls/platform.h"

#include "mbedtls/timing.h"

#include "mbedtls/entropy.h"

#include "mbedtls/error.h"

typedef struct

{

mbedtls_net_context socket_fd;

mbedtls_entropy_context entropy;

mbedtls_ctr_drbg_context ctr_drbg;

mbedtls_ssl_context ssl;

mbedtls_ssl_config ssl_conf;

mbedtls_x509_crt ca_cert;

mbedtls_x509_crt client_cert;

mbedtls_pk_context private_key;

}qtf_tls_handle_t;

#if defined(MBEDTLS_DEBUG_C)

static void _ssl_debug(void *ctx, int level, const char *file, int line, const char *str)

{

printf("[mbedTLS]:[%s]:[%d]: %s\r\n", (file), line, (str));

}

#endif

static int _mbedtls_tcp_connect(mbedtls_net_context *ctx, const char *host, uint16_t port)

{

int ret = 0;

char port_str[6] = {0};

snprintf(port_str, sizeof(port_str), "%d", port);

ret = mbedtls_net_connect(ctx, host, port_str, MBEDTLS_NET_PROTO_TCP);

if(ret != 0)

{

dlg_error("mbedtls_net_connect connect failed returned 0x%04x errno: %d", ret < 0 ? -ret : ret, errno);

return ret;

}

ret = mbedtls_net_set_block(ctx);

if(ret != 0)

{

dlg_error("mbedtls_net_set_block failed returned 0x%04x errno: %d", ret < 0 ? -ret : ret, errno);

return ret;

}

return 0;

}

static int _tls_net_init(qtf_tls_handle_t *handle, qtf_tls_conn_param_t *param)

{

int ret = -1;

mbedtls_net_init(&(handle->socket_fd));

mbedtls_ssl_init(&(handle->ssl));

mbedtls_ssl_config_init(&(handle->ssl_conf));

mbedtls_ctr_drbg_init(&(handle->ctr_drbg));

mbedtls_entropy_init(&(handle->entropy));

#if defined(MBEDTLS_DEBUG_C)

mbedtls_debug_set_threshold(param->debug_level);

mbedtls_ssl_conf_dbg(&handle->ssl_conf, _ssl_debug, NULL);

#endif

#if defined(MBEDTLS_USE_PSA_CRYPTO) || defined(MBEDTLS_SSL_PROTO_TLS1_3)

// tls 1.3 需要调用 psa_crypto_init

ret = psa_crypto_init();

if (ret != PSA_SUCCESS)

{

dlg_error("psa_crypto_init failed");

goto error;

}

#endif

ret = mbedtls_ssl_conf_max_frag_len(&(handle->ssl_conf), param->max_frag_len);

if (ret != 0)

{

dlg_error("mbedtls_ssl_conf_max_frag_len failed");

goto error;

}

ret = mbedtls_ctr_drbg_seed(&(handle->ctr_drbg), mbedtls_entropy_func, &(handle->entropy), NULL, 0);

if (ret != 0)

{

dlg_error("mbedtls_ctr_drbg_seed failed");

goto error;

}

// 证书认证方式

if(param->auth_mode == QTF_TLS_AUTH_MODE_CERT)

{

if(param->ca_cert && param->ca_cert_len)

{

mbedtls_x509_crt_init(&(handle->ca_cert));

ret = mbedtls_x509_crt_parse(&(handle->ca_cert), (const unsigned char *)param->ca_cert, param->ca_cert_len+1);

if (ret != 0)

{

dlg_error("mbedtls_x509_crt_parse failed");

goto error;

}

else

{

if(param->verify_mode != QTF_TLS_VERIFY_MODE_NONE)

{

dlg_error("invalid ca cert");

goto error;

}

dlg_info("verify mode is none");

}

mbedtls_ssl_conf_ca_chain(&(handle->ssl_conf), &(handle->ca_cert), NULL);

if (param->client_cert && param->client_cert_len && param->client_key && param->client_key_len)

{

// 双向认证

mbedtls_x509_crt_init(&(handle->client_cert));

mbedtls_pk_init(&(handle->private_key));

ret = mbedtls_x509_crt_parse(&(handle->client_cert), (const unsigned char *)param->client_cert, param->client_cert_len + 1);

if (ret != 0)

{

dlg_error("mbedtls_x509_crt_parse failed");

goto error;

}

ret = mbedtls_pk_parse_key(&(handle->private_key), (const unsigned char *)param->client_key,

param->client_key_len + 1, (const unsigned char *)param->client_key_passwd, param->client_key_passwd_len + 1, NULL, NULL);

if (ret != 0)

{

dlg_error("mbedtls_pk_parse_key failed");

goto error;

}

ret = mbedtls_ssl_conf_own_cert(&(handle->ssl_conf), &(handle->client_cert), &(handle->private_key));

if (ret != 0)

{

dlg_error("mbedtls_ssl_conf_own_cert failed");

goto error;

}

// psk 认证

else if(param->auth_mode == QTF_TLS_AUTH_MODE_PSK)

{

if(param->psk && param->psk_len && param->psk_id)

{

ret = mbedtls_ssl_conf_psk(&(handle->ssl_conf), (const unsigned char *)param->psk, param->psk_len,

(const unsigned char *)param->psk_id, strlen(param->psk_id));

if (ret != 0)

{

dlg_error("mbedtls_ssl_conf_psk failed");

goto error;

}

else

{

dlg_error("invalid psk");

goto error;

}

else

{

dlg_error("invalid auth mode");

goto error;

}

return ret;

error:

return ret;

}

static int __tls_net_deinit(qtf_tls_handle_t *handle)

{

mbedtls_net_free(&(handle->socket_fd));

mbedtls_ssl_free(&(handle->ssl));

mbedtls_ssl_config_free(&(handle->ssl_conf));

mbedtls_ctr_drbg_free(&(handle->ctr_drbg));

mbedtls_entropy_free(&(handle->entropy));

mbedtls_x509_crt_free(&(handle->ca_cert));

mbedtls_x509_crt_free(&(handle->client_cert));

mbedtls_pk_free(&(handle->private_key));

return 0;

}

void *qtf_tls_connect(const char *host, uint16_t port, qtf_tls_conn_param_t *param)

{

qtf_tls_handle_t *handle = NULL;

int ret = 0;

if(!host || !param)

{

dlg_error("invalid param");

goto error;

}

handle = (qtf_tls_handle_t *)malloc(sizeof(qtf_tls_handle_t));

if(!handle)

{

dlg_error("malloc failed");

goto error;

}

// 配置 tls 连接参数

ret = _tls_net_init(handle, param);

if(ret != 0)

{

dlg_error("tls net init failed");

goto error;

}

dlg_info("Connecting to %s:%d...", host, port);

// 建立 tcp 连接

ret = _mbedtls_tcp_connect(&(handle->socket_fd), host, port);

if (ret != 0)

{

dlg_error("mbedtls_tcp_connect failed");

goto error;

}

// 设置 tls 客户端

mbedtls_ssl_config_defaults(&(handle->ssl_conf), MBEDTLS_SSL_IS_CLIENT, MBEDTLS_SSL_TRANSPORT_STREAM, MBEDTLS_SSL_PRESET_DEFAULT);

mbedtls_ssl_conf_read_timeout(&(handle->ssl_conf), param->hanshake_timeout_ms);

// 配置认证等级

mbedtls_ssl_conf_authmode(&(handle->ssl_conf), param->verify_mode);

// 协议版本设置

if(param->tls_version == QTF_TLS_VERSION_TLS1_2)

{

mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);

mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);

}

else if(param->tls_version == QTF_TLS_VERSION_TLS1_3)

{

mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);

mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);

}

else

{

mbedtls_ssl_conf_max_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_3);

mbedtls_ssl_conf_min_tls_version(&(handle->ssl_conf), MBEDTLS_SSL_VERSION_TLS1_2);

}

mbedtls_ssl_conf_rng(&(handle->ssl_conf), mbedtls_ctr_drbg_random, &(handle->ctr_drbg));

// todo: config ciphersuites

ret = mbedtls_ssl_setup(&(handle->ssl), &(handle->ssl_conf));

if (ret != 0)

{

dlg_error("mbedtls_ssl_setup failed");

goto error;

}

// 配置 tcp 收发函数，可自定义也可使用 mbedtls 的实现

mbedtls_ssl_set_bio(&(handle->ssl), &(handle->socket_fd), mbedtls_net_send, mbedtls_net_recv, mbedtls_net_recv_timeout);

// 设置服务器域名，目的是配置 SNI （Server Name Indication）扩展。

ret = mbedtls_ssl_set_hostname(&(handle->ssl), host);

if (ret != 0)

{

dlg_error("mbedtls_ssl_set_hostname failed");

goto error;

}

// 执行握手流程

while ((ret = mbedtls_ssl_handshake(&(handle->ssl))) != 0)

{

if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)

{

dlg_error("mbedtls_ssl_handshake failed 0x%04x", ret < 0 ? -ret : ret);

goto error;

}

// 证书校验结果

ret = mbedtls_ssl_get_verify_result(&(handle->ssl));

if (ret < 0)

{

dlg_error("mbedtls_ssl_get_verify_result 0x%04x", ret < 0 ? -ret : ret);

goto error;

}

return handle;

error:

if(handle)

{

__tls_net_deinit(handle);

free(handle);

}

return NULL;

}

int qtf_tls_send(void *handle, const void *buf, uint32_t len, uint32_t timeout_ms)

{

qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;

int ret = 0;

if(!handle || !buf || !len)

{

dlg_error("invalid param");

return -1;

}

// 发送数据

while ((ret = mbedtls_ssl_write(&(tls_handle->ssl), (const unsigned char *)buf, len)) <= 0)

{

if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)

{

dlg_error("mbedtls_ssl_write failed 0x%04x", ret < 0 ? -ret : ret);

return -1;

}

return ret;

}

int qtf_tls_recv(void *handle, void *buf, uint32_t len, uint32_t timeout_ms)

{

qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;

int ret = 0;

if(!handle || !buf || !len)

{

dlg_error("invalid param");

return -1;

}

// 接收数据

while ((ret = mbedtls_ssl_read(&(tls_handle->ssl), (unsigned char *)buf, len)) <= 0)

{

if (ret != MBEDTLS_ERR_SSL_WANT_READ && ret != MBEDTLS_ERR_SSL_WANT_WRITE)

{

dlg_error("mbedtls_ssl_read failed 0x%04x", ret < 0 ? -ret : ret);

return -1;

}

return ret;

}

int qtf_tls_close(void *handle)

{

int ret = 0;

qtf_tls_handle_t *tls_handle = (qtf_tls_handle_t *)handle;

if (!handle)

{

dlg_error("invalid param");

return -1;

}

// 关闭连接，释放资源

{

ret = mbedtls_ssl_close_notify(&(tls_handle->ssl));

} while (ret == MBEDTLS_ERR_SSL_WANT_READ || ret == MBEDTLS_ERR_SSL_WANT_WRITE);

__tls_net_deinit(tls_handle);

free(tls_handle);

return 0;

}

测试例子

测试代码，连接 https 测试服务器 httpbin.org，发送一个 get 请求，并接收服务器回复。

void shell_tlstest_cmd(int argc, char *argv)
{
	qtf_tls_conn_param_t tls_param = {0};
	void *tls_handle = NULL;
	char recv_buf[1024] = {0};
	int ret = 0;

	const char request[] = "GET /get?a=1 HTTP/1.1\r\n"
		"Host: httpbin.org\r\n"
		"Connection: close\r\n"
		"\r\n";
	const char *test_ca_cert =
		{

			"-----BEGIN CERTIFICATE-----\r\n"
			"MIIDdTCCAl2gAwIBAgILBAAAAAABFUtaw5QwDQYJKoZIhvcNAQEFBQAwVzELMAkG\r\n"
			"A1UEBhMCQkUxGTAXBgNVBAoTEEdsb2JhbFNpZ24gbnYtc2ExEDAOBgNVBAsTB1Jv\r\n"
			"b3QgQ0ExGzAZBgNVBAMTEkdsb2JhbFNpZ24gUm9vdCBDQTAeFw05ODA5MDExMjAw\r\n"
			"MDBaFw0yODAxMjgxMjAwMDBaMFcxCzAJBgNVBAYTAkJFMRkwFwYDVQQKExBHbG9i\r\n"
			"YWxTaWduIG52LXNhMRAwDgYDVQQLEwdSb290IENBMRswGQYDVQQDExJHbG9iYWxT\r\n"
			"aWduIFJvb3QgQ0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDaDuaZ\r\n"
			"jc6j40+Kfvvxi4Mla+pIH/EqsLmVEQS98GPR4mdmzxzdzxtIK+6NiY6arymAZavp\r\n"
			"xy0Sy6scTHAHoT0KMM0VjU/43dSMUBUc71DuxC73/OlS8pF94G3VNTCOXkNz8kHp\r\n"
			"1Wrjsok6Vjk4bwY8iGlbKk3Fp1S4bInMm/k8yuX9ifUSPJJ4ltbcdG6TRGHRjcdG\r\n"
			"snUOhugZitVtbNV4FpWi6cgKOOvyJBNPc1STE4U6G7weNLWLBYy5d4ux2x8gkasJ\r\n"
			"U26Qzns3dLlwR5EiUWMWea6xrkEmCMgZK9FGqkjWZCrXgzT/LCrBbBlDSgeF59N8\r\n"
			"9iFo7+ryUp9/k5DPAgMBAAGjQjBAMA4GA1UdDwEB/wQEAwIBBjAPBgNVHRMBAf8E\r\n"
			"BTADAQH/MB0GA1UdDgQWBBRge2YaRQ2XyolQL30EzTSo//z9SzANBgkqhkiG9w0B\r\n"
			"AQUFAAOCAQEA1nPnfE920I2/7LqivjTFKDK1fPxsnCwrvQmeU79rXqoRSLblCKOz\r\n"
			"yj1hTdNGCbM+w6DjY1Ub8rrvrTnhQ7k4o+YviiY776BQVvnGCv04zcQLcFGUl5gE\r\n"
			"38NflNUVyRRBnMRddWQVDf9VMOyGj/8N7yy5Y0b2qvzfvGn9LhJIZJrglfCm7ymP\r\n"
			"AbEVtQwdpf5pLGkkeB6zpxxxYu7KyJesF12KwvhHhm4qxFYxldBniYUr+WymXUad\r\n"
			"DKqC5JlR3XC321Y9YeRq4VzW9v493kHMB65jUr9TU/Qr6cf9tveCX4XSQRjbgbME\r\n"
			"HMUfpIBvFSDJ3gyICh3WZlXi/EjJKSZp4A==\r\n"
			"-----END CERTIFICATE-----"};
	tls_param.auth_mode = QTF_TLS_AUTH_MODE_CERT;
	tls_param.verify_mode = QTF_TLS_VERIFY_MODE_OPTIONAL;
	tls_param.hanshake_timeout_ms = 10000;
	tls_param.ca_cert = test_ca_cert;
	tls_param.ca_cert_len = strlen(test_ca_cert);
	tls_param.client_cert = NULL;
	tls_param.client_cert_len = 0;
	tls_param.client_key = NULL;
	tls_param.client_key_len = 0;
	tls_param.client_key_passwd = NULL;
	tls_param.client_key_passwd_len = 0;
	tls_param.psk = NULL;
	tls_param.psk_len = 0;
	tls_param.psk_id = NULL;
	tls_param.debug_level = QTF_TLS_DEBUG_LEVEL_ERROR;
	tls_param.tls_version = QTF_TLS_VERSION_TLS1_2;
	tls_param.max_frag_len = QTF_TLS_MAX_FRAG_LEN_NO_USE;

	tls_handle = qtf_tls_connect("httpbin.org", 443, &tls_param);
	if(tls_handle)
	{
		shell_printf("tls connect success\r\n");
	}
	else
	{
		shell_printf("tls connect failed\r\n");
		return;
	}

	ret = qtf_tls_send(tls_handle, request, strlen(request), 1000);
	if(ret > 0)
	{
		shell_printf("tls send success\r\n");
	}
	else
	{
		shell_printf("tls send failed\r\n");
		qtf_tls_close(tls_handle);
		return;
	}

	ret = qtf_tls_recv(tls_handle, recv_buf, sizeof(recv_buf), 1000);
	if(ret > 0)
	{
		shell_printf("tls recv success\r\n");
		shell_printf("recv:%s\r\n", recv_buf);
	}
	else
	{
		shell_printf("tls recv failed\r\n");
	}

	qtf_tls_close(tls_handle);

}

void shell_tlstest_cmd(int argc, char *argv)

{

qtf_tls_conn_param_t tls_param = {0};

void *tls_handle = NULL;

char recv_buf[1024] = {0};

int ret = 0;

const char request[] = "GET /get?a=1 HTTP/1.1\r\n"

"Host: httpbin.org\r\n"

"Connection: close\r\n"

"\r\n";

const char *test_ca_cert =

{

"-----BEGIN CERTIFICATE-----\r\n"

"MIIDdTCCAl2gAwIBAgILBAAAAAABFUtaw5QwDQYJKoZIhvcNAQEFBQAwVzELMAkG\r\n"

"A1UEBhMCQkUxGTAXBgNVBAoTEEdsb2JhbFNpZ24gbnYtc2ExEDAOBgNVBAsTB1Jv\r\n"

"b3QgQ0ExGzAZBgNVBAMTEkdsb2JhbFNpZ24gUm9vdCBDQTAeFw05ODA5MDExMjAw\r\n"

"MDBaFw0yODAxMjgxMjAwMDBaMFcxCzAJBgNVBAYTAkJFMRkwFwYDVQQKExBHbG9i\r\n"

"YWxTaWduIG52LXNhMRAwDgYDVQQLEwdSb290IENBMRswGQYDVQQDExJHbG9iYWxT\r\n"

"aWduIFJvb3QgQ0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDaDuaZ\r\n"

"jc6j40+Kfvvxi4Mla+pIH/EqsLmVEQS98GPR4mdmzxzdzxtIK+6NiY6arymAZavp\r\n"

"xy0Sy6scTHAHoT0KMM0VjU/43dSMUBUc71DuxC73/OlS8pF94G3VNTCOXkNz8kHp\r\n"

"1Wrjsok6Vjk4bwY8iGlbKk3Fp1S4bInMm/k8yuX9ifUSPJJ4ltbcdG6TRGHRjcdG\r\n"

"snUOhugZitVtbNV4FpWi6cgKOOvyJBNPc1STE4U6G7weNLWLBYy5d4ux2x8gkasJ\r\n"

"U26Qzns3dLlwR5EiUWMWea6xrkEmCMgZK9FGqkjWZCrXgzT/LCrBbBlDSgeF59N8\r\n"

"9iFo7+ryUp9/k5DPAgMBAAGjQjBAMA4GA1UdDwEB/wQEAwIBBjAPBgNVHRMBAf8E\r\n"

"BTADAQH/MB0GA1UdDgQWBBRge2YaRQ2XyolQL30EzTSo//z9SzANBgkqhkiG9w0B\r\n"

"AQUFAAOCAQEA1nPnfE920I2/7LqivjTFKDK1fPxsnCwrvQmeU79rXqoRSLblCKOz\r\n"

"yj1hTdNGCbM+w6DjY1Ub8rrvrTnhQ7k4o+YviiY776BQVvnGCv04zcQLcFGUl5gE\r\n"

"38NflNUVyRRBnMRddWQVDf9VMOyGj/8N7yy5Y0b2qvzfvGn9LhJIZJrglfCm7ymP\r\n"

"AbEVtQwdpf5pLGkkeB6zpxxxYu7KyJesF12KwvhHhm4qxFYxldBniYUr+WymXUad\r\n"

"DKqC5JlR3XC321Y9YeRq4VzW9v493kHMB65jUr9TU/Qr6cf9tveCX4XSQRjbgbME\r\n"

"HMUfpIBvFSDJ3gyICh3WZlXi/EjJKSZp4A==\r\n"

"-----END CERTIFICATE-----"};

tls_param.auth_mode = QTF_TLS_AUTH_MODE_CERT;

tls_param.verify_mode = QTF_TLS_VERIFY_MODE_OPTIONAL;

tls_param.hanshake_timeout_ms = 10000;

tls_param.ca_cert = test_ca_cert;

tls_param.ca_cert_len = strlen(test_ca_cert);

tls_param.client_cert = NULL;

tls_param.client_cert_len = 0;

tls_param.client_key = NULL;

tls_param.client_key_len = 0;

tls_param.client_key_passwd = NULL;

tls_param.client_key_passwd_len = 0;

tls_param.psk = NULL;

tls_param.psk_len = 0;

tls_param.psk_id = NULL;

tls_param.debug_level = QTF_TLS_DEBUG_LEVEL_ERROR;

tls_param.tls_version = QTF_TLS_VERSION_TLS1_2;

tls_param.max_frag_len = QTF_TLS_MAX_FRAG_LEN_NO_USE;

tls_handle = qtf_tls_connect("httpbin.org", 443, &tls_param);

if(tls_handle)

{

shell_printf("tls connect success\r\n");

}

else

{

shell_printf("tls connect failed\r\n");

return;

}

ret = qtf_tls_send(tls_handle, request, strlen(request), 1000);

if(ret > 0)

{

shell_printf("tls send success\r\n");

}

else

{

shell_printf("tls send failed\r\n");

qtf_tls_close(tls_handle);

return;

}

ret = qtf_tls_recv(tls_handle, recv_buf, sizeof(recv_buf), 1000);

if(ret > 0)

{

shell_printf("tls recv success\r\n");

shell_printf("recv:%s\r\n", recv_buf);

}

else

{

shell_printf("tls recv failed\r\n");

}

qtf_tls_close(tls_handle);

}

测试日志：

[qt_idf_tls.c:250 qtf_tls_connect] Connecting to httpbin.org:443...
[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001d)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0017)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0018)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001e)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0019)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001a)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001b)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001c)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_tls.c]:[7384]: x509_verify_cert() returned -9984 (-0x2700)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_tls12_client.c]:[2762]: Perform PSA-based ECDH computation.

tls connect success
tls send success
tls recv success
recv:HTTP/1.1 200 OK
Date: Sun, 02 Jul 2023 12:02:04 GMT
Content-Type: application/json
Content-Length: 220
Connection: close
Server: gunicorn/19.9.0
Access-Control-Allow-Origin: *
Access-Control-Allow-Credentials: true

{
  "args": {
    "a": "1"
  },
  "headers": {
    "Host": "httpbin.org",
    "X-Amzn-Trace-Id": "Root=1-64a1673a-5197ca4a2ff801443ac81bc6"
  },
  "origin": "223.73.211.183",
  "url": "https://httpbin.org/get?a=1"
}

[qt_idf_tls.c:250 qtf_tls_connect] Connecting to httpbin.org:443...

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001d)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0017)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0018)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001e)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(0019)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001a)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001b)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_client.c]:[258]: got supported group(001c)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_tls.c]:[7384]: x509_verify_cert() returned -9984 (-0x2700)

[mbedTLS]:[D:/workspace/QT/qt_idf/components/mbedtls/library/ssl_tls12_client.c]:[2762]: Perform PSA-based ECDH computation.

tls connect success

tls send success

tls recv success

recv:HTTP/1.1 200 OK

Date: Sun, 02 Jul 2023 12:02:04 GMT

Content-Type: application/json

Content-Length: 220

Connection: close

Server: gunicorn/19.9.0

Access-Control-Allow-Origin: *

Access-Control-Allow-Credentials: true

{

"args": {

"a": "1"

"headers": {

"Host": "httpbin.org",

"X-Amzn-Trace-Id": "Root=1-64a1673a-5197ca4a2ff801443ac81bc6"

"origin": "223.73.211.183",

"url": "https://httpbin.org/get?a=1"

}

View Fullscreen

参考链接

mbedtls tls 客户端应用详解

Xcode 16 调整 Provisioning Profiles 目录导致证书查不到

cronet demo 使用的 ninja 打包，查找 Provisioning Profiles 路径是 ~/Library/MobileDevice/Provisioning Profiles，但 Xcode 16 把该路径改为了 ~/Library/Developer/Xcode/UserData/Provisioning Profiles，导致在编译 cronet 的 demo 时找不到证书。

解决办法是把 Xcode 16 的路径下的证书拷贝一份到老的路径 ~/Library/MobileDevice/Provisioning Profiles 即可。

参考链接

Xcode16 调整 Provisioning Profiles 目录导致证书查不到

Mac应用第三方渠道发布指南

1.申请证书

Mac 应用有多种证书，主要包含以下几种：

Apple Development: Xcode 11之后Apple全平台开发证书
Apple Distribution: Xcode 11之后Apple全平台发布
Mac Development：用来开发和Debug的证书
Mac App Distribution：用来给APP文件签名后上传到Mac App Store
Mac Installer Distribution：用来给PKG文件签名后上传到Mac App Store
Developer ID Installer：用于给PKG文件签名，在非Mac App Store场景使用
Developer ID Application：用于给APP文件签名，在非Mac App Store场景使用

这里直接申请 Developer ID Application 证书，申请过程中需要使用 Mac 本地证书助理来创建证书签名请求，按照指引一步步完成即可。

申请完成后下载证书并在本地安装。

2.申请 App ID

也就是平常大家所说的 Bundle ID，这里跟普通 iOS App 是完全一致的，选择 APP IDs 即可，正常填写相关内容。

3.生成描述文件

这里同样选择生成 Developer ID 描述文件

然后选择 Mac 应用，并填写刚才申请的 App ID 。

4.本地工程配置

本地安装证书，描述文件，并在工程配置里的 Signing & Capabilities 填写刚才申请的 App ID（Bundle ID）和描述文件

5.对App文件进行签名和公证

开发完成后使用 Xcode 自带工具对 App 文件进行签名和公证。

首先选择 Product->Archive 生成 App 文件，注意这里的步骤要登陆证书对应的开发者账号。

之后使用 Distribute App 选项对 App 进行公证，这里并不是 App 审核，是苹果推出的一个针对 Mac 第三方 App 的安全机制，在 Mac OS 10.15 之后，没有公证的 APP 打开会出现错误信息。

这里同样选择 Developer ID ，之后选择 Upload 或 Export 即可导出 App 文件，其中 Upload 会由 App Store 进行公证，速度还是很快的，几分钟之内就公证完毕了。

6.打包dmg文件

对 App 文件进行签名公证后最后一步就是打包生成 dmg 文件，这样打开后可以直接拖动 .app 文件到 Application 文件夹中，这里使用 create—dmg工具

// 安装create-dmg

brew install create-dmg

//使用create-dmg

create-dmg \

  --volname "Application Installer" \

  --volicon "application_icon.icns" \

  --background "installer_background.png" \

  --window-pos 200 120 \

  --window-size 800 400 \

  --icon-size 100 \

  --icon "Application.app" 200 190 \

  --hide-extension "Application.app" \

  --app-drop-link 600 185 \

  "Application-Installer.dmg" \

  "source_folder/"

// 安装create-dmg

brew install create-dmg

//使用create-dmg

create-dmg \

--volname "Application Installer" \

--volicon "application_icon.icns" \

--background "installer_background.png" \

--window-pos 200 120 \

--window-size 800 400 \

--icon-size 100 \

--icon "Application.app" 200 190 \

--hide-extension "Application.app" \

--app-drop-link 600 185 \

"Application-Installer.dmg" \

"source_folder/"

具体选项可以参考 create-dmg 的 GitHub 主页，需要注意的是 App 文件要放进 source_folder 文件夹里。

最后就得到一个可以任意安装的 dmg 文件啦，Mac 应用打包完成！

7.FAQ

如果在执行公证的时候：

公证过程

出现如下报错：

Hardened Runtime（强化运行时）是 Apple 在 macOS 中引入的一项安全机制，用于加强 App 的保护能力，防止被恶意注入、调试或篡改。

它是 App Notarization（公证）和沙盒（App Sandbox）安全体系的基础之一。凡是要进行公证或上架 App Store 的 macOS App，目前（2025/08/23）都必须开启 Hardened Runtime。

如果你的项目中没有添加 Hardened Runtime，则需要点击项目名 – TARGETS – 应用名称 – Signing & Capabilities，点击“+ Capability”按钮，选择 Hardened Runtime。

如果点安装包报错不能启动。使用命令行启动报错如下：

% open xxxx.app The application cannot be opened for an unexpected reason, error=Error Domain=RBSRequestErrorDomain Code=5 "Launch failed." UserInfo={NSLocalizedFailureReason=Launch failed., NSUnderlyingError=0x60000189c0f0 {Error Domain=NSPOSIXErrorDomain Code=111 "Unknown error: 111" UserInfo={NSLocalizedDescription=Launchd job spawn failed}}}

1
2
3

% open xxxx.app

The application cannot be opened for an unexpected reason, error=Error Domain=RBSRequestErrorDomain Code=5 "Launch failed." UserInfo={NSLocalizedFailureReason=Launch failed., NSUnderlyingError=0x60000189c0f0 {Error Domain=NSPOSIXErrorDomain Code=111 "Unknown error: 111" UserInfo={NSLocalizedDescription=Launchd job spawn failed}}}

点击 “显示包内容” 进入应用程序目录，然后查看 Contents/MacOS/ 下的执行程序，发现是白色的，如下图：

而不是黑色的左上角带 exec 执行标记的样子，如下：

此问题大概率是由于安装包里的程序没有可执行权限导致的，执行如下命令授予执行权限即可。

命令参考如下：

$ chmod +x /Applications/xxx.app/Contents/MacOS/xxx

1

$ chmod +x /Applications/xxx.app/Contents/MacOS/xxx

参考链接

Flutter编写HTTPS服务器

从磁盘加载证书：

import 'dart:io';

void main() async {
  var chain =
      Platform.script.resolve('certificates/server_chain.pem').toFilePath();
  var key = Platform.script.resolve('certificates/server_key.pem').toFilePath();
  var context = SecurityContext()
    ..useCertificateChain(chain)
    ..usePrivateKey(key, password: 'dartdart');
  var server =
      await HttpServer.bindSecure(InternetAddress.anyIPv6, 443, context);
  await server.forEach((HttpRequest request) {
    request.response.write('Hello, world!');
    request.response.close();
  });
}

import 'dart:io';

void main() async {

var chain =

Platform.script.resolve('certificates/server_chain.pem').toFilePath();

var key = Platform.script.resolve('certificates/server_key.pem').toFilePath();

var context = SecurityContext()

..useCertificateChain(chain)

..usePrivateKey(key, password: 'dartdart');

var server =

await HttpServer.bindSecure(InternetAddress.anyIPv6, 443, context);

await server.forEach((HttpRequest request) {

request.response.write('Hello, world!');

request.response.close();

});

}

从内存加载证书：

import 'dart:io';

void main() async {
    /// 签名私钥，PEM格式，规范要求：除了开头结尾的 BEGIN / END，以及证书的最后一行外，每行 64个字符，且不能包含空格字符
    final String privateKey = '''
-----BEGIN PRIVATE KEY-----
................................................................
-----END PRIVATE KEY-----
''';

  /// 签名公钥，规范要求：除了开头结尾的 BEGIN / END，以及证书的最后一行外，每行 64个字符，且不能包含空格字符
    final String publicKey = '''
-----BEGIN CERTIFICATE-----
................................................................
-----END CERTIFICATE-----
''';

    var context = SecurityContext()
      ..useCertificateChainBytes(publicKey.codeUnits)
      ..usePrivateKeyBytes(privateKey.codeUnits);
    var server = await HttpServer.bindSecure(
        InternetAddress.loopbackIPv6, 443, context);
    await server.forEach((HttpRequest request) {
      request.response.write('Hello, world!');
      request.response.close();
    });
}

import 'dart:io';

void main() async {

/// 签名私钥，PEM格式，规范要求：除了开头结尾的 BEGIN / END，以及证书的最后一行外，每行 64个字符，且不能包含空格字符

final String privateKey = '''

-----BEGIN PRIVATE KEY-----

................................................................

-----END PRIVATE KEY-----

''';

/// 签名公钥，规范要求：除了开头结尾的 BEGIN / END，以及证书的最后一行外，每行 64个字符，且不能包含空格字符

final String publicKey = '''

-----BEGIN CERTIFICATE-----

................................................................

-----END CERTIFICATE-----

''';

var context = SecurityContext()

..useCertificateChainBytes(publicKey.codeUnits)

..usePrivateKeyBytes(privateKey.codeUnits);

var server = await HttpServer.bindSecure(

InternetAddress.loopbackIPv6, 443, context);

await server.forEach((HttpRequest request) {

request.response.write('Hello, world!');

request.response.close();

});

}

参考链接

Java环境下 SslSocket 服务端及客户端简单例子

客户端代码如下:

import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;

import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;

public class SslClient {
     private SSLSocket s;
     private DataOutputStream out;
     private DataInputStream in;
 
     public SslClient() throws IOException {
     }
 
     public void sendMessage(Socket s, String msg) {
         try { 
             out = new DataOutputStream(s.getOutputStream());
             String jsonString = msg;
             out.write(jsonString.getBytes());
         } catch (IOException e) {
         }
 
     }
 
     public String receiveMessage(Socket s) {
         try {
             in = new DataInputStream(s.getInputStream());
             BufferedReader socketIn = new BufferedReader(new InputStreamReader(in));// 接受到
             String res = socketIn.readLine();
             if (res == null || res.equals("null")) {
                 res = "";
             }
             return res;
         } catch (Exception e) {
             return "";
         }
 
     }
 
     public String talk(String ip, int port, String trustStore, String trustStorePassword, int socketOutTime, String msg)
             throws Exception {
         try {
             int connectTimeout = socketOutTime * 1000;//设置超时时间
             System.setProperty("javax.net.ssl.trustStore", trustStore);// 设置可信任的密钥仓库
             System.setProperty("javax.net.ssl.trustStorePassword", trustStorePassword); // 设置可信任的密钥仓库的密码
             SSLSocketFactory sslsf = (SSLSocketFactory) SSLSocketFactory.getDefault();// 利用工厂来创建SSLSocket安全套接字
             s = (SSLSocket) sslsf.createSocket();
             s.connect(new InetSocketAddress(ip, port), connectTimeout);
             s.startHandshake();
 
             System.out.println("向服务器发送:" + msg);
             sendMessage(s, msg); 
             // 发字符串
             String result = receiveMessage(s);
             System.out.println("服务器返回:" + result);
             out.close();
             in.close();
             if (s != null) {
                 s.close();
             }
             return result;
 
         } catch (Exception e) {
             e.printStackTrace();
             out.close();
             in.close();
             if (s != null) {
                 s.close();
             }
             return "";
         }
 
     }
 
     public static void main(String[] args) throws Exception {
         SslClient c = new SslClient();
         String responseMsg = c.talk("xxx.xxx.xxx.xxx", 8089, "D:\\xxxx\\shfqtruststore.jks", "123456", 5, "test\n");
         System.out.println(responseMsg);
 
     } 
}

import java.io.*;

import java.net.InetSocketAddress;

import java.net.Socket;

import javax.net.ssl.SSLSocket;

import javax.net.ssl.SSLSocketFactory;

public class SslClient {

private SSLSocket s;

private DataOutputStream out;

private DataInputStream in;

public SslClient() throws IOException {

}

public void sendMessage(Socket s, String msg) {

try {

out = new DataOutputStream(s.getOutputStream());

String jsonString = msg;

out.write(jsonString.getBytes());

} catch (IOException e) {

}

public String receiveMessage(Socket s) {

try {

in = new DataInputStream(s.getInputStream());

BufferedReader socketIn = new BufferedReader(new InputStreamReader(in));// 接受到

String res = socketIn.readLine();

if (res == null || res.equals("null")) {

res = "";

}

return res;

} catch (Exception e) {

return "";

}

public String talk(String ip, int port, String trustStore, String trustStorePassword, int socketOutTime, String msg)

throws Exception {

try {

int connectTimeout = socketOutTime * 1000;//设置超时时间

System.setProperty("javax.net.ssl.trustStore", trustStore);// 设置可信任的密钥仓库

System.setProperty("javax.net.ssl.trustStorePassword", trustStorePassword); // 设置可信任的密钥仓库的密码

SSLSocketFactory sslsf = (SSLSocketFactory) SSLSocketFactory.getDefault();// 利用工厂来创建SSLSocket安全套接字

s = (SSLSocket) sslsf.createSocket();

s.connect(new InetSocketAddress(ip, port), connectTimeout);

s.startHandshake();

System.out.println("向服务器发送:" + msg);

sendMessage(s, msg);

// 发字符串

String result = receiveMessage(s);

System.out.println("服务器返回:" + result);

out.close();

in.close();

if (s != null) {

s.close();

}

return result;

} catch (Exception e) {

e.printStackTrace();

out.close();

in.close();

if (s != null) {

s.close();

}

return "";

}

public static void main(String[] args) throws Exception {

SslClient c = new SslClient();

String responseMsg = c.talk("xxx.xxx.xxx.xxx", 8089, "D:\\xxxx\\shfqtruststore.jks", "123456", 5, "test\n");

System.out.println(responseMsg);

}

服务端代码如下:

//服务端代码如下   参考 https://blog.csdn.net/spdxspdx/article/details/84230574 
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.security.KeyManagementException;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.UnrecoverableKeyException;
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 SSLServer {
     public static void startSSLServer() throws IOException, java.security.cert.CertificateException {
         int port = 8089;// 监听端口
         String keyFile = "D:\\xxxx\\shfqkeystore.jks";// 密钥库文件
         String keyFilePass = "123456";// 密钥库的密码
         String keyPass = "123456";// 密钥别名的密码
         SSLServerSocket sslsocket = null;// 安全连接套接字
         KeyStore ks;// 密钥库
         KeyManagerFactory kmf;// 密钥管理工厂
         SSLContext sslc = null;// 安全连接方式
         // 初始化安全连接的密钥
         try {
             ks = KeyStore.getInstance("JKS");
             ks.load(new FileInputStream(keyFile), keyFilePass.toCharArray());
             kmf = KeyManagerFactory.getInstance("SunX509");
             kmf.init(ks, keyPass.toCharArray());
             sslc = SSLContext.getInstance("SSLv3");
             sslc.init(kmf.getKeyManagers(), null, null);
         } catch (KeyManagementException ex) {
             ex.printStackTrace();
         } catch (UnrecoverableKeyException ex) {
             ex.printStackTrace();
         } catch (KeyStoreException ex) {
             ex.printStackTrace();
         } catch (NoSuchAlgorithmException ex) {
             ex.printStackTrace();
         }
         // 用安全连接的工厂来创建安全连接套接字
         SSLServerSocketFactory sslssf = sslc.getServerSocketFactory();
         sslsocket = (SSLServerSocket) sslssf.createServerSocket(port);// 创建并进入监听
         System.out.println("Listening...");
         while (true) {
             SSLSocket ssocket = (SSLSocket) sslsocket.accept();// 接受客户端的连接
             System.out.println("Server Connection .....");
             // 以下代码同socket通讯实例中的代码
             BufferedReader socketIn = new BufferedReader(new InputStreamReader(ssocket.getInputStream()));
             DataOutputStream socketOut = new DataOutputStream(ssocket.getOutputStream());
             String s = null;
             System.out.println("Please wait client 's message..");
             s = socketIn.readLine();
             System.out.println("Client Message: " + s); 
             
             s = "接收成功";
             System.out.print("Server Message: " + s);
             socketOut.write(s.getBytes());
             ssocket.close();
         }
 
     }
 
     public static void main(String[] args) {
         try {
             startSSLServer();
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
}

//服务端代码如下参考 https://blog.csdn.net/spdxspdx/article/details/84230574

import java.io.BufferedReader;

import java.io.DataOutputStream;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.security.KeyManagementException;

import java.security.KeyStore;

import java.security.KeyStoreException;

import java.security.NoSuchAlgorithmException;

import java.security.UnrecoverableKeyException;

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 SSLServer {

public static void startSSLServer() throws IOException, java.security.cert.CertificateException {

int port = 8089;// 监听端口

String keyFile = "D:\\xxxx\\shfqkeystore.jks";// 密钥库文件

String keyFilePass = "123456";// 密钥库的密码

String keyPass = "123456";// 密钥别名的密码

SSLServerSocket sslsocket = null;// 安全连接套接字

KeyStore ks;// 密钥库

KeyManagerFactory kmf;// 密钥管理工厂

SSLContext sslc = null;// 安全连接方式

// 初始化安全连接的密钥

try {

ks = KeyStore.getInstance("JKS");

ks.load(new FileInputStream(keyFile), keyFilePass.toCharArray());

kmf = KeyManagerFactory.getInstance("SunX509");

kmf.init(ks, keyPass.toCharArray());

sslc = SSLContext.getInstance("SSLv3");

sslc.init(kmf.getKeyManagers(), null, null);

} catch (KeyManagementException ex) {

ex.printStackTrace();

} catch (UnrecoverableKeyException ex) {

ex.printStackTrace();

} catch (KeyStoreException ex) {

ex.printStackTrace();

} catch (NoSuchAlgorithmException ex) {

ex.printStackTrace();

}

// 用安全连接的工厂来创建安全连接套接字

SSLServerSocketFactory sslssf = sslc.getServerSocketFactory();

sslsocket = (SSLServerSocket) sslssf.createServerSocket(port);// 创建并进入监听

System.out.println("Listening...");

while (true) {

SSLSocket ssocket = (SSLSocket) sslsocket.accept();// 接受客户端的连接

System.out.println("Server Connection .....");

// 以下代码同socket通讯实例中的代码

BufferedReader socketIn = new BufferedReader(new InputStreamReader(ssocket.getInputStream()));

DataOutputStream socketOut = new DataOutputStream(ssocket.getOutputStream());

String s = null;

System.out.println("Please wait client 's message..");

s = socketIn.readLine();

System.out.println("Client Message: " + s);

s = "接收成功";

System.out.print("Server Message: " + s);

socketOut.write(s.getBytes());

ssocket.close();

}

public static void main(String[] args) {

try {

startSSLServer();

} catch (Exception e) {

e.printStackTrace();

}

1 SSL单向认证概念

当客户端（服务请求方）向服务端（服务提供方）发起请求时，服务器端需要向客户端提供认证。服务端需要生成一个keystore和一个服务器密钥对儿（公钥和私钥），客户端需要生成一个truststore，然后导入服务端的公钥证书。

2 keystore以及服务器密钥对儿的生成

keytool -genkeypair -alias certificatekey -keyalg RSA -validity 365 -keystore shfqkeystore.jks

1	keytool -genkeypair -alias certificatekey -keyalg RSA -validity 365 -keystore shfqkeystore.jks

这条命令会在生成 keystore 后接着生成一个密钥对儿。RSA是非对称密钥算法，也可以改为 keytool支持的其他密钥算法，365 代表的是证书的有效期，可以自己指定，shfqkeystore.jks 是 keystroe 的名称，也可以自己指定。打开 cmd 命令行，输入：

keytool -genkeypair -alias certificatekey -keyalg RSA -validity 365 -keystore shfqkeystore.jks

1	keytool -genkeypair -alias certificatekey -keyalg RSA -validity 365 -keystore shfqkeystore.jks

会提示输入 keystore 的密码，接着会提示输入名字等信息，如下图：

补充：输入<certificatekey>的主密码，是指生成服务端证书的私钥。服务端私钥如果和keystore的相同的话，直接按回车。建议直接按回车，即服务端私钥和keystore的密码相同。如果两者的密码不相同的话在服务端tomcat server.xml中配置完毕以后启动tomcat会报一个 UnrecoverableKeyException: Cannot recover key 的异常（后面会介绍服务端 tomcat server.xml 的配置的）。

keytool会把生成的keystore文件默认保存到C:\Users\lenovo路径下（用户目录下的计算机名称下）接下来生成的所有文件也都保存到此处。

3 验证新生成的keystor文件以及证书信息

可以执行下面的命令：

keytool -list -v -keystore shfqkeystore.jks

1	keytool -list -v -keystore shfqkeystore.jks

会显示出以下信息，如图：

4 导出公钥证书

下面的命令可以导出自签公钥证书：

keytool -export -alias certificatekey -keystore shfqkeystore.jks -rfc -file shfqcert.cer

1	keytool -export -alias certificatekey -keystore shfqkeystore.jks -rfc -file shfqcert.cer

其中shfqcert.cer是导出证书的名称，可以随便起个名字，shfqkeystore.jks是2中生成的keystore 文件。

执行上面的命令会要求输入shfqkeystore的密码，会显示以下信息，如下图。

5 Truststore的生成以及公钥证书的导入

把4生成的公钥证书shfqcert.cer导入到truststore中

Keytool -import -alias certificatekey -file shfqcert.cer -keystore shfqtruststore.jks

1	Keytool -import -alias certificatekey -file shfqcert.cer -keystore shfqtruststore.jks

shfqcert.cer是4导出的公钥证书，shfqtruststore.jks可以随便起，是生成的truststore的文件名。这条命令首先会生成一个truststore，然后导入4生成的公钥证书shfqcert.cer。

执行

keytool -import -alias certificatekey -file shfqcert.cer  -keystore shfqtruststore.jks

1	keytool -import -alias certificatekey -file shfqcert.cer -keystore shfqtruststore.jks

后，首先会提示输入 truststore 的密码，如下图：

6 验证5生成的truststore文件

keytool -list -v -keystore shfqtruststore.jks

1	keytool -list -v -keystore shfqtruststore.jks

shfqtruststore.jks是5生成的truststore文件名。

到此为止，keystore、truststore、公钥证书都已生成完毕。

参考链接

Java环境下 SslSocket 服务端及客户端简单例子

网页检测微信登录状态

现在很多网站、应用平台在登录的时候，都支持直接通过微信扫码登录。

最近我发现一个现象：以前需要扫二维码才能登录，而现在，如果你的电脑上已经运行了微信，它能直接检测到，然后点击一个按钮就可以实现登录了。

比如知识星球以前是微信扫码登录，而现在，它会自动检测到展示下面的画面：

然后，程序员的敏感神经触发，让我开始思考：它是咋知道我电脑上已经运行了微信，并且登录的是这个账号呢？

要知道，知识星球只是一个运行在 Chrome 浏览器的网页应用，它是不可能拥有 native 权限，去做什么进程扫描检测之类的事儿的。

直接祭出 F12 大法，来看看到底发生了什么。

在网络连接这里，我发现了一堆的 check-login 请求：

这一堆请求里面只有一个是成功的，其他都失败了。仔细一看，请求的域名都是 localhost.weixin.qq.com，只不过端口在变化，最后在 13013 端口请求成功了。

一看这个域名，localhost.weixin.qq.com，而且解析的 IP 地址是 127.0.0.1？

难道 hosts 里面被下药了？

打开 hosts 文件一看，没啥异常啊。然后 nslookup 看了一下，还真是 DNS 返回的 IP 地址它就是 127.0.0.1，有点意思。

请求 127.0.0.1 的 13013 端口，那本地又是哪个进程在配合监听这个端口呢？我估计你已经猜到了，就是微信的进程。

最后看看知识星球网页里面，发起这个请求的 JS 代码是啥？

至此，真相大白了：

像知识星球这样的第三方应用通过微信的官方接口接入微信登录功能，然后接入的 JS 代码里面会去请求 localhost.weixin.qq.com 这个域名的 13013 等多个端口，来检查本地是否有微信账户已经登录了。

而腾讯把这个域名映射到了本机的 127.0.0.1。再在客户端这边监听一下 13013 这个端口，就能实现在网页里面和本地的微信进程进行通信了。

参考链接

Flutter 的生命周期

概述

生命周期是一个 widget 组件加载到卸载的整个周期，熟悉生命周期可以让我们在合适的时机做该做的事情。

在 Flutter 开发中，everything is widget，但我们一般都不用直接继承 Widget 类来实现一个新组件，我们通常会通过继承 StatelessWidget 或 StatefulWidget 来间接继承 Widget 类来实现。StatelessWidget 和StatefulWidget 都是直接继承自 Widget 类，而这两个类也正是 Flutter 中非常重要的两个抽象类，它们引入了两种 Widget 模型。此文主要介绍这两种 widget 的生命周期。

StatelessWidget

StatelessWidget 是无状态的 Widget，一旦创建就不会发生变化，所以无法提供 setState 修改组件的状态，它内部属性应声明为 final，防止意外发生改变。所以 StatelessWidget 的生命周期只有一个，就是 build，build 是用来创建 Widget 的，但因为 build 在每次界面刷新的时候都会调用，所以不要在 build 里写业务逻辑，可以把业务逻辑写到你的 StatelessWidget 的构造函数里。其生命周期如下图：

StatefulWidget

StatefulWidget 是有状态的 Widget，它的 state 在发生变化时会重新渲染 UI，提供 setState 方法修改组件的状态，它的生命周期主要在 State 这块，其生命周期如下图:

下面解释下各个函数：

initState：当 Widget 第一次插入到 Widget 树时会被调用；对于每一个 State 对象，Flutter Framework 只会调用一次该回调，所以，通常在该回调中做一些一次性的操作，如状态初始化、订阅子树的事件通知等 。不能在该回调中调用 BuildContext.dependOnInheritedWidgetOfExactType（该方法用于在 Widget 树上获取离当前 widget 最近的一个父级 InheritFromWidget），原因是在初始化完成后，Widget 树中的 InheritFromWidget 也可能会发生变化，所以正确的做法应该在在 build 方法或 didChangeDependencies 中调用它。
didChangeDependencies()：当 State 对象的依赖发生变化时会被调用；比如其所依赖的 InheritedWidget 发生变化时， Framework 会调用此方法通知组件发生变化。典型的场景是当系统语言 Locale 或应用主题改变时，Flutter framework 会通知 widget 调用此回调。

注意：didChangeDependencies 方法调用后，组件的状态变为 dirty，立即调用 build 方法。

build：用于构建 Widget 的，会在如下场景被调用：
1. 在调用 initState() 之后。
2. 在调用 didUpdateWidget() 之后。
3. 在调用 setState() 之后。
4. 在调用 didChangeDependencies() 之后。
5. 在 State 对象从树中一个位置移除后（会调用 deactivate ）又重新插入到树的其它位置之后。

注意：此方法中应该只包含构建组件的代码，不应该包含其他额外的功能，尤其是耗时任务。

reassemble()：此回调是专门为了开发调试而提供的，在热重载( hot reload )时会被调用，此回调在 Release 模式下永远不会被调用。
didUpdateWidget()：在父 widget 重新构建子 widget 时，子 widget 的 didUpdateWidget 可能会被调用。之所以说可能，是因为在父 widget 重新构建时，Flutter Framework 会调用 Widget.canUpdate 来检测Widget 树中同一位置的新旧节点的 key 和 runtimeType 是否同时相等，新旧 widget 的 key 和 runtimeType 同时相等时会返回 true，此时 didUpdateWidget() 就会被调用，如果新旧节点的 key 和 runtimeType 没有同时相等，didUpdateWidget() 不会被调用。

注意：Framework 调用完此方法后，会将组件设置为 dirty 状态，然后调用 build 方法。

deactivate()：当 State 对象从树中被移除时，会调用此回调。在一些场景下，Flutter Framework 会将 State 对象重新插到树中，如包含此 State 对象的子树在树的一个位置移动到另一个位置时（可以通过 GlobalKey 来实现）。如果移除后没有重新插入到树中则紧接着会调用 dispose() 方法。
dispose()：当 State 对象从树中被永久移除时调用；通常在此回调中释放资源。

实例展示

展示随机数的一个 demo，点击随机按钮，更新随机数，打印此 demo 的生命周期函数的调用流程，代码如下：

import 'dart:math';
import 'package:flutter/material.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {

  @override
  Widget build(BuildContext context) {
    // TODO: implement build
    return MaterialApp(
      home: Scaffold(
        body: RandomPage(),
      ),
    );
  }

}

class RandomPage extends StatefulWidget {

  @override
  State<StatefulWidget> createState() {
    // TODO: implement createState
    return _RandomPageState();
  }

}

class _RandomPageState extends State<RandomPage> {
  final _randomBuild = Random();
  int _randomValue = 0;

  @override
  void initState() {
    // TODO: implement initState
    super.initState();
    print('initState');
  }

 
  @override
  void didChangeDependencies() {
    // TODO: implement didChangeDependencies
    super.didChangeDependencies();
    print('didChangeDependencies');
  }

  @override
  Widget build(BuildContext context) {
    print('build');
    // TODO: implement build
    return Container(
      child: Padding(
        padding: EdgeInsets.only(top: 100),
        child: Center(
          child: Column(
            children: [
              Text('随机数: $_randomValue'),
              SizedBox(height: 200),
              TextButton(
                child: Text('切换随机数'),
                onPressed: () {
                  setState(() {
                    _randomValue = _randomBuild.nextInt(10000);
                  });
                },
              )
            ],
          ),
        ),
      ),
    );
  }

  @override
  void reassemble() {
    // TODO: implement reassemble
    super.reassemble();
    print('reassemble');
  }

  @override
  void didUpdateWidget(covariant RandomPage oldWidget) {
    // TODO: implement didUpdateWidget
    super.didUpdateWidget(oldWidget);
    print('didUpdateWidget');
  }

  @override
  void deactivate() {
    // TODO: implement deactivate
    super.deactivate();
    print('deactivate');
  }

  @override
  void dispose() {
    // TODO: implement dispose
    super.dispose();
    print('dispose');
  }
}

100

101

102

103

104

105

import 'dart:math';

import 'package:flutter/material.dart';

void main() {

runApp(MyApp());

}

class MyApp extends StatelessWidget {

@override

Widget build(BuildContext context) {

// TODO: implement build

return MaterialApp(

home: Scaffold(

body: RandomPage(),

);

}

class RandomPage extends StatefulWidget {

@override

State<StatefulWidget> createState() {

// TODO: implement createState

return _RandomPageState();

}

class _RandomPageState extends State<RandomPage> {

final _randomBuild = Random();

int _randomValue = 0;

@override

void initState() {

// TODO: implement initState

super.initState();

print('initState');

}

@override

void didChangeDependencies() {

// TODO: implement didChangeDependencies

super.didChangeDependencies();

print('didChangeDependencies');

}

@override

Widget build(BuildContext context) {

print('build');

// TODO: implement build

return Container(

child: Padding(

padding: EdgeInsets.only(top: 100),

child: Center(

child: Column(

children: [

Text('随机数: $_randomValue'),

SizedBox(height: 200),

TextButton(

child: Text('切换随机数'),

onPressed: () {

setState(() {

_randomValue = _randomBuild.nextInt(10000);

});

)

);

}

@override

void reassemble() {

// TODO: implement reassemble

super.reassemble();

print('reassemble');

}

@override

void didUpdateWidget(covariant RandomPage oldWidget) {

// TODO: implement didUpdateWidget

super.didUpdateWidget(oldWidget);

print('didUpdateWidget');

}

@override

void deactivate() {

// TODO: implement deactivate

super.deactivate();

print('deactivate');

}

@override

void dispose() {

// TODO: implement dispose

super.dispose();

print('dispose');

}

点击run首次启动，打印log如下：

flutter: initState
flutter: didChangeDependencies
flutter: build

flutter: initState

flutter: didChangeDependencies

flutter: build

点击切换随机数按钮，打印 log 如下：

flutter: build

1	flutter: build

点击切换随机数按钮，会调用 setState()，setState 会调用 build 重新构建 widget。

点击 hot reload 按钮，打印 log 如下：

flutter: reassemble
flutter: didUpdateWidget
flutter: build

flutter: reassemble

flutter: didUpdateWidget

flutter: build

App生命周期

通过 WidgetsBindingObserver 的 didChangeAppLifecycleState 可以获取 App 的生命周期状态。生命周期在 AppLifecycleState 类中。常用状态包含如下几个：

resumed：处于可见并能响应用户的输入
inactive：处于不活跃状态且无法处理用户的响应
paused：处于不可见且不能响应用户的输入，但是在后台继续活跃

举例如下：

class _RandomPageState extends State<RandomPage>
    with WidgetsBindingObserver {

  @override
  void initState() {
    super.initState();
    WidgetsBinding.instance?.addObserver(this);
  }

  @override
  void dispose() {
    WidgetsBinding.instance?.removeObserver(this);
    super.dispose();
  }

  @override
  void didChangeAppLifecycleState(AppLifecycleState state) async {
    if (state == AppLifecycleState.resumed) {
      getData();
    }
  }

  @override
  Widget build(BuildContext context) {
    // TODO: implement build
    throw UnimplementedError();
  }
  
  void getData() {
    
  }
}

class _RandomPageState extends State<RandomPage>

with WidgetsBindingObserver {

@override

void initState() {

super.initState();

WidgetsBinding.instance?.addObserver(this);

}

@override

void dispose() {

WidgetsBinding.instance?.removeObserver(this);

super.dispose();

}

@override

void didChangeAppLifecycleState(AppLifecycleState state) async {

if (state == AppLifecycleState.resumed) {

getData();

}

@override

Widget build(BuildContext context) {

// TODO: implement build

throw UnimplementedError();

}

void getData() {

}

记得注册和移除监听。

生命周期相关的一些注意点

页面渲染完毕回调 addPostFrameCallback 是 StatefulWidget 渲染结束的回调，只会被调用一次，之后 StatefulWidget 刷新 UI 也不会被调用。在 initState 不能调用BuildContext.dependOnInheritedWidgetOfExactType，可以使用 addPostFrameCallback 规避此限制：

@override 
void initState() { 
    super.initState(); 
    WidgetsBinding.instance.addPostFrameCallback((_) => {}); 
}

@override

void initState() {

super.initState();

WidgetsBinding.instance.addPostFrameCallback((_) => {});

}

mounted

mounted 是 State 对象中的一个属性，此属性表示当前组件是否在树中（在创建 State 之后，调用 initState 之前，Framework 会将 State 和 BuildContext 进行关联），当 Framework 调用 dispose 时，mounted 被设置为 false，表示当前组件已经不在树中。

createState 函数执行完毕后表示当前组件已经在组件树中，属性 mounted 被 Framework 设置为 true，平时写代码时或者看其他开源代码时经常看到如下代码：

if(mounted){ 
    setState(() { ... });
}

if(mounted){

setState(() { ... });

}

强烈建议：在调用 setState 时加上 mounted 判断。

为什么要加上如此判断？因为如果当前组件未插入到树中或者已经从树中移除时，调用 setState 会抛出异常，加上 mounted 判断，则表示当前组件在树中。

dirty 和 clean

dirty 表示组件当前的状态为脏状态，下一帧时将会执行 build 函数，调用 setState 方法或者执行 didUpdateWidget 方法后，组件的状态为 dirty。

clean 与 dirty 相对应，clean 表示组件当前的状态为干净状态，clean 状态下组件不会执行 build 函数。

参考链接

Flutter 的生命周期

Flutter手势冲突难题怎么破？几种解决方式大揭秘！

在 Flutter 应用开发中，手势处理是构建交互式界面的核心环节。然而当多个手势识别器或可滚动组件嵌套使用时，经常会出现手势冲突问题。

本文将深入探讨 Flutter 中解决手势冲突的各种方法，并分析其适用场景，帮助您掌握高效的手势管理策略。

1 手势冲突的根源

在理解如何解决手势冲突之前，我们需要先了解 Flutter 中手势系统的基本原理 :

Flutter 的手势识别基于 GestureRecognizer 竞争机制。当用户触发指针事件（PointerDown）时，多个手势识别器会进入 gesture arena 竞争，最终只有一个胜出。竞争的过程主要有两个阶段：

命中测试阶段（Hit Test Phase）：确定哪些 Widget 接收了手势事件。
手势识别阶段（Gesture Recognition Phase）：多个 Widget 可能会识别相同的手势，从而产生冲突。

开发过程中比较常见的手势冲突场景包括：

嵌套滚动组件（如 PageView 中的 ListView）
多层手势检测器（如 InkWell 内部的 GestureDetector）
父子组件都监听相同类型手势事件
多个手势识别器同时竞争同一区域

2 解决手势冲突的方式

针对不同的应用场景，Flutter 提供了不同的冲突的处理方式

2.1 HitTestBehavior (最轻量级)

通过控制 GestureDetector 的 behavior 参数控制手势事件如何在Widget 树中传递。常见的 behavior 值有：

HitTestBehavior.translucent : 自身和子组件都能接收事件
HitTestBehavior.opaque: 拦截所有事件（即使透明区域）
HitTestBehavior.deferToChild: 默认值，优先传给子组件

有兴趣的话，可以尝试改变内外两个 GestureDetector 的 behavior 的值来加深理解对这个处理方式的理解

GestureDetector(
  behavior: HitTestBehavior.translucent, // 允许手势穿透
  onTap: () => print('Outer tapped'),
  child: Container(
    width: 200,
    height: 200,
    color: Colors.blue,
    child: GestureDetector(
      behavior: HitTestBehavior.translucent,
      onTap: () => print('Inner tapped'),
      child: Container(
        width: 100,
        height: 100,
        color: Colors.red,
      ),
    ),
  ),
);

GestureDetector(

behavior: HitTestBehavior.translucent, // 允许手势穿透

onTap: () => print('Outer tapped'),

child: Container(

width: 200,

height: 200,

color: Colors.blue,

child: GestureDetector(

behavior: HitTestBehavior.translucent,

onTap: () => print('Inner tapped'),

child: Container(

width: 100,

height: 100,

color: Colors.red,

);

适用场景

父子组件都需要响应手势
需要控制手势事件的传递层次(通过 behavior )
简单按钮嵌套

2.2 AbsorbPointer/IgnorePointer组件

这两个组件在使用时，会完成拦截或忽略掉所有的手势：

IgnorePointer：使子 Widget 忽略所有手势事件，但仍会参与布局和绘制；
AbsorbPointer：拦截并消耗所有手势事件，子 Widget 无法接收手势，自身可以接收并处理事件。

适用场景：

临时禁用某个区域的手势
阻止下层 Widget 接收手势事件;
复杂UI中动态切换交互状态;

// 阻止事件继续传递
AbsorbPointer(
  child: GestureDetector(
    onTap: () => print('This will absorb all taps'),
    child: Container(color: Colors.red),
  ),
)

// 自身和子组件完全忽略事件
IgnorePointer(
  child: GestureDetector(
    onTap: () => print('This will never be called'),
    child: Container(color: Colors.green),
  ),
)

// 阻止事件继续传递

AbsorbPointer(

child: GestureDetector(

onTap: () => print('This will absorb all taps'),

child: Container(color: Colors.red),

)

// 自身和子组件完全忽略事件

IgnorePointer(

child: GestureDetector(

onTap: () => print('This will never be called'),

child: Container(color: Colors.green),

)

2.3 RawGestureDetector与手势竞技场

Flutter 的手势竞技场（ GestureArena ）机制允许自定义手势识别的竞争规则,通过使用底层的 RawGestureDetector 注册多个手势识别器,由手势竞技场决定胜出者，整个竞技的过程会经历

当指针按下时，所有识别器进入竞技场
通过 addPointer() 处理事件流
识别器声明是否"准备好"处理事件
竞技场选择获胜者（首个声明准备就绪的识别器）
胜出者接收后续事件，其他被拒绝

RawGestureDetector(
  gestures: {
    AllowMultipleGestureRecognizer: 
      GestureRecognizerFactoryWithHandlers<AllowMultipleGestureRecognizer>(
        () => AllowMultipleGestureRecognizer(),
        (instance) => instance..onTap = () => print('Tapped'),
      ),
    LongPressGestureRecognizer: 
      GestureRecognizerFactoryWithHandlers<LongPressGestureRecognizer>(
        () => LongPressGestureRecognizer(),
        (instance) => instance..onLongPress = () => print('Long Press'),
      ),
  },
  child: Container(color: Colors.amber),
)

RawGestureDetector(

gestures: {

AllowMultipleGestureRecognizer:

GestureRecognizerFactoryWithHandlers<AllowMultipleGestureRecognizer>(

() => AllowMultipleGestureRecognizer(),

(instance) => instance..onTap = () => print('Tapped'),

LongPressGestureRecognizer:

GestureRecognizerFactoryWithHandlers<LongPressGestureRecognizer>(

() => LongPressGestureRecognizer(),

(instance) => instance..onLongPress = () => print('Long Press'),

child: Container(color: Colors.amber),

)

适用场景

需要同时识别多种手势
复杂手势组合（缩放+旋转+平移）
自定义手势识别逻辑

2.4 Listener组件处理原始指针事件

直接通过 Listener 去处理最原始的指针事件，自由控制：

Listener(
  onPointerDown: (event) {
    print('Pointer down at ${event.position}');
    // 可阻止事件传播
    // event.stopPropagation();
  },
  onPointerMove: (event) => print('Pointer move'),
  onPointerUp: (event) => print('Pointer up'),
  // 还有其他的指针事件
  child: Container(color: Colors.purple),

)
   // 里面的指针事件，可按需使用
  // const Listener({
  // super.key,
  // this.onPointerDown,
  // this.onPointerMove,
  // this.onPointerUp,
  // this.onPointerHover,
  // this.onPointerCancel,
  // this.onPointerPanZoomStart,
  // this.onPointerPanZoomUpdate,
  // this.onPointerPanZoomEnd,
  // this.onPointerSignal,
  // this.behavior = HitTestBehavior.deferToChild,
  // super.child,

Listener(

onPointerDown: (event) {

print('Pointer down at ${event.position}');

// 可阻止事件传播

// event.stopPropagation();

onPointerMove: (event) => print('Pointer move'),

onPointerUp: (event) => print('Pointer up'),

// 还有其他的指针事件

child: Container(color: Colors.purple),

)

// 里面的指针事件，可按需使用

// const Listener({

// super.key,

// this.onPointerDown,

// this.onPointerMove,

// this.onPointerUp,

// this.onPointerHover,

// this.onPointerCancel,

// this.onPointerPanZoomStart,

// this.onPointerPanZoomUpdate,

// this.onPointerPanZoomEnd,

// this.onPointerSignal,

// this.behavior = HitTestBehavior.deferToChild,

// super.child,

适用场景

需要底层事件控制的场景
高度定制化的交互需求
性能关键型的手势处理

2.5 自定义 ScrollPhysics

通过继承 ScrollPhysics 类，可以自定义滚动行为，控制滚动事件的传递和处理。

class CustomScrollPhysics extends ScrollPhysics {
  const CustomScrollPhysics({super.parent});

  @override
  CustomScrollPhysics applyTo(ScrollPhysics? ancestor) {
    return CustomScrollPhysics(parent: buildParent(ancestor));
  }

   @override
  bool shouldAcceptUserOffset(ScrollMetrics position) {
    // 自定义逻辑：决定是否接受用户滚动
    return super.shouldAcceptUserOffset(position);
  }

  @override
  Simulation? createBallisticSimulation(ScrollMetrics position, double velocity) {
    if (velocity == 0.0 || position.minScrollExtent == position.maxScrollExtent) {
      return null;
    }

    final spring = SpringDescription.withDampingRatio(
      mass: 1.0,
      stiffness: 200.0,
      ratio: 1.0,
    );

    // 判断是否滚动到最底下了 
    if (velocity > 0 && position.pixels >= position.maxScrollExtent) {
      return ScrollSpringSimulation(
        spring: spring,
        start: position.pixels,
        end: position.maxScrollExtent + 100,
        velocity: velocity,
        tolerance: Tolerance.defaultTolerance,
      );
      // 判断是否滚动到最顶了
    } else if (velocity < 0 && position.pixels <= position.minScrollExtent) {
      return ScrollSpringSimulation(
        spring: spring,
        start: position.pixels,
        end: position.minScrollExtent - 100,
        velocity: velocity,
        tolerance: Tolerance.defaultTolerance,
      );
    }

    return super.createBallisticSimulation(position, velocity);
  }
}

// 使用自定义 ScrollPhysics
ListView(
  physics: CustomScrollPhysics(),
  children: [...],
);

class CustomScrollPhysics extends ScrollPhysics {

const CustomScrollPhysics({super.parent});

@override

CustomScrollPhysics applyTo(ScrollPhysics? ancestor) {

return CustomScrollPhysics(parent: buildParent(ancestor));

}

@override

bool shouldAcceptUserOffset(ScrollMetrics position) {

// 自定义逻辑：决定是否接受用户滚动

return super.shouldAcceptUserOffset(position);

}

@override

Simulation? createBallisticSimulation(ScrollMetrics position, double velocity) {

if (velocity == 0.0 || position.minScrollExtent == position.maxScrollExtent) {

return null;

}

final spring = SpringDescription.withDampingRatio(

mass: 1.0,

stiffness: 200.0,

ratio: 1.0,

);

// 判断是否滚动到最底下了

if (velocity > 0 && position.pixels >= position.maxScrollExtent) {

return ScrollSpringSimulation(

spring: spring,

start: position.pixels,

end: position.maxScrollExtent + 100,

velocity: velocity,

tolerance: Tolerance.defaultTolerance,

);

// 判断是否滚动到最顶了

} else if (velocity < 0 && position.pixels <= position.minScrollExtent) {

return ScrollSpringSimulation(

spring: spring,

start: position.pixels,

end: position.minScrollExtent - 100,

velocity: velocity,

tolerance: Tolerance.defaultTolerance,

);

}

return super.createBallisticSimulation(position, velocity);

}

// 使用自定义 ScrollPhysics

ListView(

physics: CustomScrollPhysics(),

children: [...],

);

适用场景

嵌套滚动组件（如 PageView 与 ListView 的冲突）
需要精确控制滚动阈值和边界条件

2.6 使用 NotificationListener

通过监听滚动通知（如 ScrollNotification），可以在父组件中捕获并处理滚动事件，从而控制子组件的行为。

NotificationListener<ScrollNotification>(
  onNotification: (notification) {
    if (notification is ScrollStartNotification) {
      print('Scroll started');
    } else if (notification is ScrollEndNotification) {
      print('Scroll ended');
    }
    // 返回 true 会拦截通知，阻止传递给子组件
    return false; 
  },
  child: ListView(
    children: [...],
  ),
);

NotificationListener<ScrollNotification>(

onNotification: (notification) {

if (notification is ScrollStartNotification) {

print('Scroll started');

} else if (notification is ScrollEndNotification) {

print('Scroll ended');

}

// 返回 true 会拦截通知，阻止传递给子组件

return false;

child: ListView(

children: [...],

);

适用场景

监听滚动状态并作出响应
协调多层级滚动组件的行为

3 手势冲突的例子

项目的某一个场景中，会有一个 PageView 里面嵌套 ScrollView 的场景，而且这两个的滚动方向是一致的（都是竖向的滚动）。

这种情况下要怎样保证当 ScrollView 滑动到最底（最顶）时，能触发 PageView的 翻页呢？结合前面的介绍的处理手势冲突的几种方式，大家会选择哪个呢？

最开始笔者是选择了自定义 ScrollPhysics 的方式来尝试处理的，但发现最终也只能有一个组件能滚动（中间尝试不同解决方案的痛苦就一一细说了），这里最终是通过NotificationListener 来协调这两者的滚动的。(这个方案不一定是最好的)

PageView.builder(
                itemCount: dataLength,
                controller: _pageController,
                scrollDirection: Axis.vertical,
                onPageChanged: (int index) {
                  _curPageIndex.value = index;
                },
                itemBuilder: (BuildContext context, int index) {
                	return NotificationListener<ScrollNotification>(
                            onNotification: (ScrollNotification scroll) {
                            	// 通过判断
                              if (scroll is ScrollEndNotification) {
                                final pixels = scroll.metrics.pixels;
                                final maxScroll =
                                    scroll.metrics.maxScrollExtent;

                                if (pixels == maxScroll) {
                                  // 滚动到底部，触发翻页
                                  _pageController.nextPage(
                                    duration: Duration(milliseconds: 300),
                                    curve: Curves.easeInOut,
                                  );
                                } else if (pixels == 0.0) {
                                  // 滚动到顶部，触发上一页
                                  _pageController.previousPage(
                                    duration: Duration(milliseconds: 300),
                                    curve: Curves.easeInOut,
                                  );
                                }
                              }
                              return false;
                            },
                            child: SingleChildScrollView(child:Column(....))
                            );
                }

PageView.builder(

itemCount: dataLength,

controller: _pageController,

scrollDirection: Axis.vertical,

onPageChanged: (int index) {

_curPageIndex.value = index;

itemBuilder: (BuildContext context, int index) {

return NotificationListener<ScrollNotification>(

onNotification: (ScrollNotification scroll) {

// 通过判断

if (scroll is ScrollEndNotification) {

final pixels = scroll.metrics.pixels;

final maxScroll =

scroll.metrics.maxScrollExtent;

if (pixels == maxScroll) {

// 滚动到底部，触发翻页

_pageController.nextPage(

duration: Duration(milliseconds: 300),

curve: Curves.easeInOut,

);

} else if (pixels == 0.0) {

// 滚动到顶部，触发上一页

_pageController.previousPage(

duration: Duration(milliseconds: 300),

curve: Curves.easeInOut,

);

}

return false;

child: SingleChildScrollView(child:Column(....))

);

}

4 总结

本文主要介绍了 Flutter 中手势冲突几种解决方案，从简单高效的 AbsorbPointer 到底层强大的 Listener，可以应对不同复杂度的交互场景。

可以根据不同的业务场景选择不同的解决方案，这里给几点在选择解决方案时可参考的点：

准确识别冲突来源和类型
评估交互的复杂程度
考虑性能和维护成本

参考链接

Flutter手势冲突难题怎么破？几种解决方式大揭秘！

OpenBB的介绍以及如何使用OpenBB助力A股港股的金融数据分析

OpenBB 是一个开源的金融数据平台，旨在为投资者、分析师、研究人员和开发者提供免费、透明且易于使用的金融与宏观经济数据访问接口。它曾被认为是类似于彭博终端（Bloomberg Terminal）的功能性替代品，但完全开放源码，用户可以自由定制和扩展。

在一些文章中将 OpenBB 解释为 Open Bloomberg，这是个误解。尽管它常被视为“开源版彭博终端”，但其名称中的“BB”实际上源自黑莓公司的股票代码，而 OpenBB 的创始人此前曾在黑莓股票上亏损。

📜 OpenBB 的历史背景

OpenBB 的前身是由 Didier Lopes 在 2021 年创建的开源项目 Gamestonk Terminal。2021 年 3 月，Gamestonk Terminal 1.0 版本正式发布，凭借其独特的功能和开源特性，迅速在市场上崭露头角，并于同年成功获得第一笔风险投资。基于该项目的良好发展态势，新公司于 2022 年正式成立，并将公司和项目更名为 OpenBB。

请参考创始人Didier Lopes的这篇文章 GME didn’t take me to the moon, but Gamestonk terminal did。

OpenBB的发展时间线如下:

2020 年第四季度：Didier 开启 Gamestonk Terminal 的开发之旅
2021 年第一季度：Gamestonk Terminal 正式上线
2021 年第二季度：Joeseph Jacks 与开发团队展开合作洽谈
2021 年第三季度：OpenBB 项目宣告成立
2021 年第四季度：获得 850 万美元的初始投资
2022 年第一季度：OpenBB 正式发布

从 Gamestonk Terminal 到 OpenBB Terminal，其产品开发思路与传统金融终端类似，是一款集成众多数据源的开源金融终端产品。和著名的 Bloomberg Terminal 一样，OpenBB Terminal 对不同数据源的数据进行了抽象化和标准化处理，这种特性显著提升了金融分析从业人员的工作效率，也使得 OpenBB Terminal 在短时间内吸引了大量用户。

OpenBB Platform

随着 OpenBB Terminal 的用户规模不断扩大，项目团队面临着巨大的维护压力。正如创始人 Didier Lopes 在文章中提到，维护这个免费开源终端，包括添加数据集、处理 500 多个 Python 包依赖项以及应对数据源端点更新等工作，所投入的资源对于初创公司来说难以持续。

关于停止 OpenBB Terminal 的开发决定，请参考文章 Sunsetting OpenBB Terminal: Why, How, and What now?。

在实际金融数据分析中，投资者往往面临复杂的数据获取问题。例如，多元化投资者的资产可能涉及多个币种和股票市场，需要从不同数据源收集数据并进行计算，这一过程不仅耗时，而且重复性高。虽然可以通过编写 Python 脚本来自动拉取数据，但随着时间推移，会遇到数据源接口变更和数据需求多样化的难题。

基于这些问题，OpenBB 开发团队重新审视产品价值，决定在 2024 年一季度发布 OpenBB Platform 取代 OpenBB Terminal。OpenBB Platform 专注于金融数据的抽象化和标准化，开发者能够自由添加所需数据源。以查询历史股价为例，无论选择哪种数据源，都可使用统一接口：

from openbb import obb
prices = obb.equity.price.historical(symbol='000002', start_date="2025-05-01", end_date="2025-05-30", provider="yfinance")

1 2	from openbb import obb prices = obb.equity.price.historical(symbol='000002', start_date="2025-05-01", end_date="2025-05-30", provider="yfinance")

用户可以根据自身需求，灵活选择默认或指定的数据源，无论是免费还是付费的数据源都能适配。

随着产品升级，OpenBB 的用户界面也进化为 OpenBB Platform CLI，它结合了命令行工具和 WebView，为调用 OpenBB API 提供了便捷环境。在命令行中查询股价历史的示例命令如下：

2025 Jun 25, 21:35 (🦋) /equity/price/ $ historical --symbol 000002 --provider akshare --start_date 2025-05-01 --end_date 2025-05-30

1	2025 Jun 25, 21:35 (🦋) /equity/price/ $ historical --symbol 000002 --provider akshare --start_date 2025-05-01 --end_date 2025-05-30

执行该命令后，WebView 会展示查询结果。

OpenBB Workspace

OpenBB Platform CLI 更适合开发者和具备编程能力的金融分析人员，而对于企业用户，OpenBB 团队推出了 OpenBB Workspace 解决方案，也被称为 OpenBB Terminal Pro。它虽然并非全开源产品，但有望为团队带来收益，目前是 OpenBB 团队的主要开发方向。

通过参考 OpenBB 官方文章中的架构图（整合了 2024 年 3 月及后续关于私有化部署和 AI 集成的示意图），可以清晰了解其产品定义。

关于这个架构图，参考下面这篇文章 Exploring the architecture behind the OpenBB Platform

开源的 OpenBB Platform 是金融分析应用的基础，在此之上，前端部分不断发展。从 2025 年 6 月起，OpenBB Bot 转由 Unusual Whales 运营，OpenBB Workspace 也转变为基于 AI 的可定制方案。企业用户能够基于 OpenBB Platform 和自身数据，将 OpenBB Workspace 定制为兼具金融终端功能和 AI 能力的专属金融分析平台，相比传统昂贵的金融终端，具有显著优势。为增强灵活性和可定制性，OpenBB 开源了 OpenBB Workspace 的后端和 AI Agent 的集成部分，除用户界面组件外，数据集成方案和 OpenBB Copilot 都支持定制。

OpenBB Workspace Backend
https://github.com/OpenBB-finance/backends-for-openbb

OpenBB Agents
https://github.com/OpenBB-finance/agents-for-openbb

OpenBB与AI的集成

OpenBB 针对企业用户和开发者，分别提供了不同的 AI 使用方式，其与 AI 的集成主要体现在以下两个层面：

OpenBB Platform - LLM Friendly Mode：专为开发者设计的集成方法
OpenBB Workspace - OpenBB Copilot：主要面向企业用户的使用方式

LLM Friendly Mode

在 API 层面，OpenBB Platform 的 LLM 友好模式，极大地降低了开发者将 OpenBB 数据模型集成到 AI 应用中的难度。OpenBB 开放的函数接口能够轻松转换为 LLM 的函数调用，官方提供的示例代码如下：

from magentic import prompt_chain, FunctionCall, OpenaiChatModel

@prompt_chain(
"You are a helpful financial agent that can use function calling to retrieve data.\nUser Query: {query}",
functions=[obb.equity.price.quote],
model=OpenaiChatModel(model="gpt-4-turbo-preview")
)
def llm(query: str) -> FunctionCall | str: ...

r = llm(query="What is the current stock price of AAPL?")
r

from magentic import prompt_chain, FunctionCall, OpenaiChatModel

@prompt_chain(

"You are a helpful financial agent that can use function calling to retrieve data.\nUser Query: {query}",

functions=[obb.equity.price.quote],

model=OpenaiChatModel(model="gpt-4-turbo-preview")

)

def llm(query: str) -> FunctionCall | str: ...

r = llm(query="What is the current stock price of AAPL?")

上述代码创建了一段 LLM 对话，并将 OpenBB 的股价查询函数obb.equity.price.quote作为 LLM 的函数调用，方便快捷地实现数据获取。

OpenBB Copilot

对于企业用户而言，OpenBB Workspace 提供的 OpenBB Copilot 功能十分实用。用户可以依据当前仪表板内容，借助 AI 进行深度分析。例如，在查看辽港股份资料后，通过 OpenBB Copilot 获取 2025 年投资建议，其分析结果和行业对比总结具有较高的参考价值。

上图中，使用的 Equity Template 模板在查询中国股市数据时存在部分空白项，如当前股票新闻、收入分析等。从辽港股份股票代码601880.SS的查询情况来看，中国股市数据主要依赖 Yahoo Finance，但该数据源对于中国股市数据分析存在局限性，OpenBB 若能支持更多本地化主流数据源，将更贴合中国市场需求。

中国市场的金融数据源

在中国金融市场，主流数据源大多需要付费使用，其中 Wind、东方财富 Choice 和同花顺 iFind 是行业内常用的数据源。除付费数据源外，也有一些可靠的开源数据源可供选择，如 AKShare 和 TuShare：

AKShare - https://github.com/akfamily/akshare

TuShare - https://github.com/waditu/tushare

通过开发 OpenBB Platform 的数据源扩展，接入中国市场专有的数据源，能够进一步提升 OpenBB 在中国市场金融分析领域的实用性和竞争力。

📝 总结

OpenBB 是一个功能强大、开源免费、面向未来金融数据需求的综合平台。无论你是想了解市场动态、构建投资组合，还是进行深度数据分析，OpenBB 都能为你提供强有力的支持。随着其生态系统的不断发展，OpenBB 正逐渐成为新一代金融科技爱好者的首选工具。

2025 年 9 月
一	二	三	四	五	六	日
1	2	3	4	5	6	7
8	9	10	11	12	13	14
15	16	17	18	19	20	21
22	23	24	25	26	27	28
29	30