远程MongoDB连接异常：Spring Boot解码URI后报MongoSocketReadException

首先，你遇到的com.mongodb.MongoSocketReadException: Prematurely reached end of stream异常，通常和解码后的URI格式错误或者MongoClient配置缺失关键参数有关——毕竟直接用明文URI能正常运行，说明网络和MongoDB服务本身是没问题的。下面一步步排查解决：

1. 先验证解码后的URI是否完全正确 #

先确认解码后的URI和原始明文URI完全一致，尤其是特殊字符（比如@、:、/、?后面的参数）有没有被错误转义或丢失。

可以在配置类里临时打印解码后的URI，和原始明文URI对比：

String encodedUri = environment.getProperty("spring.data.mongodb.uri.encoded");
String decodedUri = new String(Base64.getUrlDecoder().decode(encodedUri));
System.out.println("解码后的URI: " + decodedUri);
// 和原始明文URI逐字符对比，确保完全一致

注意：如果你的编码用的是普通Base64而非URL安全的，记得换成Base64.getDecoder()，但更推荐用URL安全的编码方式处理URI，避免特殊字符编码冲突。

2. 正确构建MongoTemplate的配置类 #

如果解码后的URI没问题，那可能是配置类创建MongoClient的方式不对。下面是一个标准的配置类示例，确保解码后正确初始化MongoClient和MongoTemplate：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.core.MongoTemplate;
import com.mongodb.client.MongoClients;
import org.springframework.core.env.Environment;
import java.util.Base64;

@Configuration
public class MongoConfig {

    private final Environment environment;

    public MongoConfig(Environment environment) {
        this.environment = environment;
    }

    @Bean
    public MongoTemplate mongoTemplate() {
        // 获取配置文件中编码后的URI
        String encodedUri = environment.getProperty("spring.data.mongodb.uri.encoded");
        // 解码URI（根据你的实际编码方式调整解码逻辑）
        String decodedUri = new String(Base64.getUrlDecoder().decode(encodedUri));
        
        // 用解码后的URI创建MongoClient，再初始化MongoTemplate
        return new MongoTemplate(MongoClients.create(decodedUri), "your-database-name");
    }
}

记得替换your-database-name为你实际的数据库名，也可以从配置文件读取数据库名，避免硬编码。

3. 添加必要的连接超时配置 #

有时候即使URI正确，也可能因为连接/读取超时导致这个异常。你可以通过两种方式配置超时：

方式1：在解码后的URI中追加参数 #

给解码后的URI添加超时参数（数值根据你的需求调整）：

mongodb://username:password@host:port/dbname?connectTimeoutMS=30000&socketTimeoutMS=30000&serverSelectionTimeoutMS=30000

方式2：通过MongoClientSettings手动配置 #

如果不想修改URI，可以在配置类里直接配置超时：

import com.mongodb.MongoClientSettings;
import com.mongodb.client.MongoClients;
import org.springframework.data.mongodb.core.MongoTemplate;
import java.util.concurrent.TimeUnit;

@Bean
public MongoTemplate mongoTemplate() {
    String encodedUri = environment.getProperty("spring.data.mongodb.uri.encoded");
    String decodedUri = new String(Base64.getUrlDecoder().decode(encodedUri));
    
    MongoClientSettings settings = MongoClientSettings.builder()
            .applyConnectionString(new com.mongodb.ConnectionString(decodedUri))
            .applyToSocketSettings(builder -> 
                    builder.connectTimeout(30, TimeUnit.SECONDS)
                            .readTimeout(30, TimeUnit.SECONDS))
            .applyToClusterSettings(builder -> 
                    builder.serverSelectionTimeout(30, TimeUnit.SECONDS))
            .build();
    
    return new MongoTemplate(MongoClients.create(settings), "your-database-name");
}

4. 检查编码过程是否正确 #

最后，确保你编码URI的过程没有人为错误。比如用Java生成URL安全的Base64编码：

String originalUri = "mongodb://username:password@host:port/dbname?params...";
String encodedUri = Base64.getUrlEncoder().encodeToString(originalUri.getBytes());
// 把生成的encodedUri存入application.properties

尽量用代码自动编码，不要手动修改URI内容，避免出错。

按照上面的步骤排查，应该能解决这个异常。如果还是有问题，可以把解码后的URI（隐去敏感信息）和配置类的代码贴出来，方便进一步排查。

内容的提问来源于stack exchange，提问作者Sachin