小编Ola*_*ock的帖子

当我尝试airflow -version 和airflow initdb 时出现上述错误

  File "/home/ravi/sandbox/bin/airflow", line 26, in <module>
    from airflow.bin.cli import CLIFactory
  File "/home/ravi/sandbox/lib/python3.6/site-packages/airflow/bin/cli.py", line 70, in <module>
    from airflow.www.app import (cached_app, create_app)
  File "/home/ravi/sandbox/lib/python3.6/site-packages/airflow/www/app.py", line 37, in <module>
    from airflow.www.blueprints import routes
  File "/home/ravi/sandbox/lib/python3.6/site-packages/airflow/www/blueprints.py", line 25, in <module>
    from airflow.www import utils as wwwutils
  File "/home/ravi/sandbox/lib/python3.6/site-packages/airflow/www/utils.py", line 39, in <module>
    from flask_admin.model import filters
  File "/home/ravi/sandbox/lib/python3.6/site-packages/flask_admin/model/__init__.py", line 2, in <module>
    from .base import BaseModelView
  File "/home/ravi/sandbox/lib/python3.6/site-packages/flask_admin/model/base.py", line 8, in <module>
    from werkzeug import secure_filename
ImportError: cannot …

我正在尝试在 Spring 中设置 httpClient5 ...我有以下代码：

PoolingHttpClientConnectionManager connectionManager = PoolingHttpClientConnectionManagerBuilder.create()
                .setSSLSocketFactory(SSLConnectionSocketFactoryBuilder.create()
                        .setSslContext(SSLContexts.createSystemDefault())
                        .setTlsVersions(TLS.V_1_3, TLS.V_1_2)
                        .build())
                .setDefaultSocketConfig(SocketConfig.custom()
                        .setSoTimeout(Timeout.ofSeconds(5))
                        .build())
                .setPoolConcurrencyPolicy(PoolConcurrencyPolicy.STRICT)
                .setConnPoolPolicy(PoolReusePolicy.LIFO)
                .setConnectionTimeToLive(TimeValue.ofMinutes(1L))
                .build();

        CloseableHttpClient client = HttpClients.custom()
                .setConnectionManager(connectionManager)
                .setDefaultRequestConfig(RequestConfig.custom()
                        .setConnectTimeout(Timeout.ofSeconds(5))
                        .setResponseTimeout(Timeout.ofSeconds(5))
                        .setCookieSpec(StandardCookieSpec.STRICT)
                        .build())
                .build();

        CookieStore cookieStore = new BasicCookieStore();

        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();

        HttpClientContext clientContext = HttpClientContext.create();
        clientContext.setCookieStore(cookieStore);
        clientContext.setCredentialsProvider(credentialsProvider);
        clientContext.setRequestConfig(RequestConfig.custom()
                .setConnectTimeout(Timeout.ofSeconds(5000))
                .setResponseTimeout(Timeout.ofSeconds(5000))
                .build());



        // connect Spring httpComponent (client-side) with Apache httpClient
        HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();
        httpRequestFactory.setReadTimeout(60000);
        httpRequestFactory.setConnectTimeout(60000);
        httpRequestFactory.setHttpClient(client);

ClosableHttpClient 类实现了与 setHttpClient(client) 不兼容的接口 org.apache.hc.client5.http.classic.HttpClient ；这是运行时错误：

java.lang.ClassCastException: class org.apache.hc.client5.http.impl.classic.InternalHttpClient cannot be cast …

我正在迁移我的应用程序以使用 HttpClient5，但它一天比一天变得痛苦。许多 API 被删除，并且没有适当的文档可用于了解替代方案。Stackoverflow/任何其他网站/博客总是显示与 httpcomponents4.x 相关的答案，但这些 API 不再存在于 HttpClient5 中。我将所有查询/替代方案放在这里。如果有人知道，请回答/确认这些是否是正确的实现。

1. 在客户端上设置套接字超时：删除了RequestConfig.custom().setSocketTimeout(socketTimeout).build()API。经过大量研究，发现有单独的 SocketConfig 类需要设置ConnectionManager

    SocketConfig socketConfig=SocketConfig.custom()
                                    .setSoTimeout(Timeout.ofMilliseconds(10000))
                                    .build();
   
    BasicHttpClientConnectionManager connMgr=new BasicHttpClientConnectionManager(registry);
    connMgr.setSocketConfig(socketConfig);
   
    CloseableHttpClient httpclient = HttpClients.custom()
            .setConnectionManager(connMgr)
            .build();
   

   Run Code Online (Sandbox Code Playgroud)

2. 设置默认主机。遵循此How does one set Default HttpHost Target in Apache HttpClient 4.3+? 并发现我们可以重写determineRoute，DefaultRoutePlanner但我们不能在 httpclient5 中执行此操作，因为此方法声明为final因此无法重写。所以我这样做了：

        HttpHost targetHost = new HttpHost(myHost,myPort);
        HttpRoutePlanner planner=new HttpRoutePlanner() {
   
            @Override
            public HttpRoute determineRoute(HttpHost var1, HttpContext var2) throws HttpException {
                HttpRoute route=new HttpRoute(targetHost);//default for all requests
                return route; …

   Run Code Online (Sandbox Code Playgroud)

我正在尝试连接到需要私钥身份验证并希望使用 Mina 的 SFTP 服务器。查看文档，我可以看到如何使用密码身份验证而不是私钥身份验证来执行身份验证。我没有看到任何示例代码来演示如何使用 mina 执行私钥身份验证。

目前该库是否可行，如果可以，您能否提供有关如何加载密钥并执行连接的示例代码？

这是我想要使用 SSHTools 执行的操作的示例，以供参考。

   private static void authenticate(Ssh2Client ssh2, String host, Integer port, String username, InputStream privateKey) {
    Ssh2PublicKeyAuthentication auth = createKeyAuthentication(privateKey);

    try {
        int result = ssh2.authenticate(auth);
        if (result != SshAuthentication.COMPLETE) {
            throw new AuthenticationIncomplete(host, port, username, result);
        }
    } catch (SshException ex) {
        throw new UnableToAuthenticate(host, port, username, ex);
    }
}

private static Ssh2PublicKeyAuthentication createKeyAuthentication(InputStream privateKey) {
    try {
        SshPrivateKeyFile privateKeyFile = SshPrivateKeyFileFactory.parse(StreamUtil.readIntoByteArray(privateKey));
        SshKeyPair keyPair = privateKeyFile.toKeyPair("");

        Ssh2PublicKeyAuthentication auth = new …