HTTPDNS:Flutter プラグインの統合

2.2.1. ネイティブ SDK バージョンの確認

このプラグインは、各プラットフォーム用のネイティブ HTTPDNS SDK を統合しています。現在のバージョンは次のとおりです。

• Android： com.aliyun.ams:alicloud-android-httpdns:2.6.7

• iOS： AlicloudHTTPDNS:3.4.0

SDK のバージョンを更新するには、以下の更新手順をご参照ください。

2.2.2. Android SDK バージョンの更新

packages/aliyun_httpdns/android/build.gradle ファイルを編集し、依存関係のバージョンを変更します：

dependencies {
    implementation 'androidx.annotation:annotation:1.8.0'
    // 必要なバージョンに更新
    implementation 'com.aliyun.ams:alicloud-android-httpdns:2.6.7'
}

利用可能なバージョンについては、「Android SDK リリースノート」をご参照ください。

2.2.3. iOS SDK バージョンの更新

packages/aliyun_httpdns/ios/aliyun_httpdns.podspec ファイルを編集し、依存関係のバージョンを変更します。

Pod::Spec.new do |s|
  # ... その他の設定 ...
  
  s.dependency 'Flutter'
  # 必要なバージョンに更新
  s.dependency 'AlicloudHTTPDNS', '3.4.0'
  
  # ... その他の設定 ...
end

利用可能なバージョンについては、「iOS SDK リリースノート」をご参照ください。

2.2.4. プロジェクトの再ビルド

バージョンを更新した後、プロジェクトを再ビルドします。

Android:

flutter clean
flutter pub get
flutter build apk  # または他のビルドコマンド

iOS:

flutter clean
flutter pub get
cd ios
pod install
cd ..
flutter build ios

3.1.1. ログ設定

アプリケーション開発中に HTTPDNS ログを出力するには、ログ出力制御メソッドを呼び出してロギングを有効にします。次のコードは一例です。

await AliyunHttpdns.setLogEnabled(true);
print("enableLog success");

3.1.2. SessionId の記録

アプリケーションの実行中に、メソッドを呼び出して sessionId を取得し、アプリケーションのデータ収集システムに記録できます。sessionId は、アプリケーションの単一の実行を識別します。オンラインでのトラブルシューティング中に、特定の実行の解決ログをクエリするために使用できます。次のコードは一例です。

final sessionId = await AliyunHttpdns.getSessionId();
print("SessionId = $sessionId");

3.2. ドメイン名解決

await AliyunHttpdns.setPreResolveHosts(["www.aliyun.com", "www.example.com"], ipType: 'both');
print("preResolveHosts success");

Future<void> _resolve() async {
  final res = await AliyunHttpdns.resolveHostSyncNonBlocking('www.aliyun.com', ipType: 'both');
  final ipv4List = res['ipv4'] ?? [];
  final ipv6List = res['ipv6'] ?? [];
  print('IPv4: $ipv4List');
  print('IPv6: $ipv6List');
}

4.2.1. カスタム HTTP クライアントアダプターの実装

カスタムアダプターの実装については、lib/net/httpdns_http_client_adapter.dart ファイルをご参照ください。このソリューションは EMAS チームによって設計および実装されました。このソリューションを参照する場合は、出典を明記してください。アダプターは HTTP リクエストをインターセプトし、ドメイン名解決のために HTTPDNS を呼び出し、解決された IP アドレスを使用してソケット接続を作成します。

この例では、Dio、HttpClient、および http パッケージの 3 つのネットワークライブラリをサポートしています。コードは次のとおりです。

import 'dart:io';
import 'package:dio/io.dart';
import 'package:http/http.dart' as http;
import 'package:http/io_client.dart';
import 'package:flutter/foundation.dart';
import 'package:aliyun_httpdns/aliyun_httpdns.dart';

// Dio アダプター
IOHttpClientAdapter buildHttpdnsHttpClientAdapter() {
  final HttpClient client = HttpClient();
  _configureHttpClient(client);
  _configureConnectionFactory(client);

  final IOHttpClientAdapter adapter = IOHttpClientAdapter(createHttpClient: () => client)
    ..validateCertificate = (cert, host, port) => true;
  return adapter;
}

// ネイティブ HttpClient
HttpClient buildHttpdnsNativeHttpClient() {
  final HttpClient client = HttpClient();
  _configureHttpClient(client);
  _configureConnectionFactory(client);
  return client;
}

// http パッケージアダプター
http.Client buildHttpdnsHttpPackageClient() {
  final HttpClient httpClient = buildHttpdnsNativeHttpClient();
  return IOClient(httpClient);
}

// HttpClient の基本設定
void _configureHttpClient(HttpClient client) {
  client.findProxy = (Uri _) => 'DIRECT';
  client.idleTimeout = const Duration(seconds: 90);
  client.maxConnectionsPerHost = 8;
}

// HTTPDNS に基づく接続ファクトリの設定
// このソリューションは EMAS チームによって設計および実装されました。参照する場合は出典を明記してください。
void _configureConnectionFactory(HttpClient client) {
  client.connectionFactory = (Uri uri, String? proxyHost, int? proxyPort) async {
    final String domain = uri.host;
    final bool https = uri.scheme.toLowerCase() == 'https';
    final int port = uri.port == 0 ? (https ? 443 : 80) : uri.port;

    final List<InternetAddress> targets = await _resolveTargets(domain);
    final Object target = targets.isNotEmpty ? targets.first : domain;

    if (!https) {
      return Socket.startConnect(target, port);
    }

    // HTTPS: 最初に TCP、次に TLS (SNI=ドメイン名)、キャンセル可能に保つ
    bool cancelled = false;
    final Future<ConnectionTask<Socket>> rawStart = Socket.startConnect(target, port);
    final Future<Socket> upgraded = rawStart.then((task) async {
      final Socket raw = await task.socket;
      if (cancelled) {
        raw.destroy();
        throw const SocketException('Connection cancelled');
      }
      final SecureSocket secure = await SecureSocket.secure(
        raw,
        host: domain, // 重要: SNI として元のドメイン名を使用する
      );
      if (cancelled) {
        secure.destroy();
        throw const SocketException('Connection cancelled');
      }
      return secure;
    });
    return ConnectionTask.fromSocket(
      upgraded,
      () {
        cancelled = true;
        try {
          rawStart.then((t) => t.cancel());
        } catch (_) {}
      },
    );
  };
}

// HTTPDNS を介してターゲット IP リストを解決する
Future<List<InternetAddress>> _resolveTargets(String domain) async {
  try {
    final res = await AliyunHttpdns.resolveHostSyncNonBlocking(domain, ipType: 'both');
    final List<String> ipv4 = res['ipv4'] ?? [];
    final List<String> ipv6 = res['ipv6'] ?? [];
    final List<InternetAddress> targets = [
      ...ipv4.map(InternetAddress.tryParse).whereType<InternetAddress>(),
      ...ipv6.map(InternetAddress.tryParse).whereType<InternetAddress>(),
    ];
    if (targets.isEmpty) {
      debugPrint('[dio] HTTPDNS no result for $domain, fallback to system DNS');
    } else {
      debugPrint('[dio] HTTPDNS resolved $domain -> ${targets.first.address}');
    }
    return targets;
  } catch (e) {
    debugPrint('[dio] HTTPDNS resolve failed: $e, fallback to system DNS');
    return const <InternetAddress>[];
  }
}

4.2.2. アダプターの統合と使用方法

アダプターの統合については、lib/main.dart ファイルをご参照ください。まず、HTTPDNS を初期化します。次に、カスタムアダプターを使用するようにネットワークライブラリを設定します。次のコードは一例です。

class _MyHomePageState extends State<MyHomePage> {
  late final Dio _dio;
  late final HttpClient _httpClient;
  late final http.Client _httpPackageClient;

  @override
  void initState() {
    super.initState();
    
    // HTTPDNS の初期化
    _initHttpDnsOnce();
    
    // HTTPDNS アダプターを使用するようにネットワークライブラリを設定
    _dio = Dio();
    _dio.httpClientAdapter = buildHttpdnsHttpClientAdapter();
    _dio.options.headers['Connection'] = 'keep-alive';
    
    _httpClient = buildHttpdnsNativeHttpClient();
    _httpPackageClient = buildHttpdnsHttpPackageClient();
  }

  Future<void> _initHttpDnsOnce() async {
    try {
      await AliyunHttpdns.init(
        accountId: 139450,
        secretKey: 'Your SecretKey',
      );
      await AliyunHttpdns.setHttpsRequestEnabled(true);
      await AliyunHttpdns.setLogEnabled(true);
      await AliyunHttpdns.setPersistentCacheIPEnabled(true);
      await AliyunHttpdns.setReuseExpiredIPEnabled(true);
      await AliyunHttpdns.build();
      
      // 事前解決ホストの設定
      await AliyunHttpdns.setPreResolveHosts(['www.aliyun.com'], ipType: 'both');
    } catch (e) {
      debugPrint('[httpdns] init failed: $e');
    }
  }
}

設定済みのネットワークライブラリを使用してリクエストを行うと、自動的に HTTPDNS を使用してドメイン名解決が行われます。

// Dio を使用
final response = await _dio.get('https://www.aliyun.com');

// HttpClient を使用
final request = await _httpClient.getUrl(Uri.parse('https://www.aliyun.com'));
final response = await request.close();

// http パッケージを使用
final response = await _httpPackageClient.get(Uri.parse('https://www.aliyun.com'));

4.2.3. リソースのクリーンアップ

コンポーネントが破棄される際には、関連するリソースをクリーンアップする必要があります。

@override
void dispose() {
  _urlController.dispose();
  _httpClient.close();
  _httpPackageClient.close();
  super.dispose();
}

1. 依存関係のバージョンの更新

pubspec.yaml

dependencies:aliyun_httpdns: ^1.0.0

更新を実行します。

flutter pub upgrade aliyun_httpdns

2. 初期化コードのリファクタリング

アップグレード前

// 旧バージョン: シングルトンパターン + 1 ステップ初期化
final _aliyunHttpDns = AliyunHttpDns();

await _aliyunHttpDns.init(
  "YOUR_ACCOUNT_ID",              // String 型
  secretKey: "your_secret_key",
  aesSecretKey: "your_aes_key",
  region: "",
  timeout: 2000,
  enableHttps: true,
  enableExpireIp: true,
  enableCacheIp: true,
  enableDegradationLocalDns: true,
  preResolveAfterNetworkChanged: true,
  ipRankingMap: {"www.aliyun.com": 80},
  sdnsGlobalParam: {"aa": "bb"},
  bizTags: ["tag1", "tag2"]
);

アップグレード後

// 新バージョン: 静的メソッド + 2 段階初期化

// ステージ 1: 基本構成の初期化
await AliyunHttpdns.init(
  accountId: your_account_id,            // int 型、必須
  secretKey: "your_secret_key",          // オプション
  aesSecretKey: "your_aes_key",          // オプション
);

// ステージ 2: 機能オプションの設定
await AliyunHttpdns.setHttpsRequestEnabled(true);        // enableHttps を置き換えます
await AliyunHttpdns.setLogEnabled(true);                 // enableLog を置き換えます
await AliyunHttpdns.setPersistentCacheIPEnabled(true);   // enableCacheIp を置き換えます
await AliyunHttpdns.setReuseExpiredIPEnabled(true);      // enableExpireIp を置き換えます
await AliyunHttpdns.setPreResolveAfterNetworkChanged(true); // preResolveAfterNetworkChanged を置き換えます

// ステージ 3: サービスのビルド (呼び出し必須)
await AliyunHttpdns.build();

注:

• region、timeout、enableDegradationLocalDns、ipRankingMap、sdnsGlobalParam、および bizTags パラメーターは削除されました。

• 新しい build() メソッドが追加されました。設定完了後に呼び出す必要があります。

• すべてのメソッドは静的になりました。インスタンスを作成する必要はありません。

3. 解決 API の更新

アップグレード前

// 同期非ブロッキング、JSON 文字列を返す
String result = await _aliyunHttpDns.resolve(
  "YOUR_ACCOUNT_ID",          // accountId
  "www.aliyun.com",           // host
  kRequestIpv4AndIpv6,        // requestIpType
);

// 手動での JSON 解析が必要
Map<String, dynamic> map = json.decode(result);
List<String> ipv4s = List<String>.from(map['ipv4'] ?? []);
List<String> ipv6s = List<String>.from(map['ipv6'] ?? []);

// 最初の IP を使用
String ip = ipv4s.isNotEmpty ? ipv4s.first : '';

アップグレード後

// 同期非ブロッキング、構造化データを返す
Map<String, List<String>> result = await AliyunHttpdns.resolveHostSyncNonBlocking(
  'www.aliyun.com',           // hostname (accountId は不要)
  ipType: 'both',             // kRequestIpv4AndIpv6 の代替
);

// IP リストを直接取得
List<String> ipv4s = result['ipv4'] ?? [];
List<String> ipv6s = result['ipv6'] ?? [];

// 最初の IP を使用
String ip = ipv4s.isNotEmpty ? ipv4s.first : '';

カスタム解決パラメーター:

// アップグレード前
String result = await _aliyunHttpDns.resolve(
  "YOUR_ACCOUNT_ID",
  "www.aliyun.com",
  kRequestIpv4AndIpv6,
  params: {"key": "value"},
  cacheKey: "custom_key"
);

// アップグレード後
Map<String, List<String>> result = await AliyunHttpdns.resolveHostSyncNonBlocking(
  'www.aliyun.com',
  ipType: 'both',
  sdnsParams: {"key": "value"},    // パラメーター名が変更されました
  cacheKey: "custom_key"
);

4. 事前解決 API の更新

アップグレード前

await _aliyunHttpDns.setPreResolveHosts(
  "YOUR_ACCOUNT_ID",                     // accountId
  ["www.aliyun.com"],
  kRequestIpv4AndIpv6                    // requestIpType
);

スペックアップ後

await AliyunHttpdns.setPreResolveHosts(
  ["www.aliyun.com"],                     // accountId は不要
  ipType: 'both'                          // kRequestIpv4AndIpv6 の代替
);

5. ログ設定の更新

アップグレード前

await _aliyunHttpDns.enableLog(true);

スペックアップ後

await AliyunHttpdns.setLogEnabled(true);

6. SessionId 取得の更新

アップグレード前

String sessionId = await _aliyunHttpDns.getSessionId("YOUR_ACCOUNT_ID");

スペックアップ後

String? sessionId = await AliyunHttpdns.getSessionId();

7. 新機能の使用

キャッシュのクリア

await AliyunHttpdns.cleanAllHostCache();

永続化キャッシュ構成

await AliyunHttpdns.setPersistentCacheIPEnabled(true);