Kotlin Vert.x 项目中 Postgres pub/sub 功能无法生效问题咨询

现有代码的核心问题 #

• 语法逻辑错误：if (ar.succeeded()) 后未加大括号，只有紧跟的println会进入连接成功的分支，后续订阅频道的代码无论连接是否成功都会执行，连接失败时直接操作channel会触发不可预期的错误
• 缺少订阅动作：仅给channel设置消息处理handler，没有调用subscribe()方法执行实际的订阅操作，自然无法收到Postgres推送的通知
• 生命周期错误：Verticle的start方法中不应手动新建Vertx.vertx()实例，应该使用当前Verticle绑定的vertx实例，否则subscriber会被关联到独立的Vertx实例，容易随GC被回收或者和当前Verticle生命周期脱节
• 配置缺失：未配置数据库密码，若你的Postgres实例开启了密码校验，连接会直接失败，且你未添加连接失败的日志打印，无法感知连接错误
• 协程适配问题：在suspend修饰的协程化start方法中使用回调式API，容易出现异步时序问题，建议使用Vert.x Kotlin提供的协程拓展方法

修复后的实现代码 #

public override suspend fun start() {
    // 直接使用当前Verticle绑定的vertx实例，不要手动新建
    val subscriber = PgSubscriber.subscriber(
        vertx, PgConnectOptions()
            .setPort(5432)
            .setDatabase("postgres")
            .setHost("localhost")
            .setUser("postgres")
            .setPassword("你的数据库密码") // 补全密码配置
    )

    try {
        // 用协程await替代回调，适配suspend方法的上下文
        subscriber.connect().await()
        println("Postgres subscriber 连接成功")
        // 获取频道、设置处理器、执行订阅
        subscriber.channel("added_workspace_request")
            .handler { payload: String -> println("Received $payload") }
            .subscribe() // 必须调用才会真正向Postgres发送LISTEN指令完成订阅
    } catch (e: Exception) {
        println("订阅失败: ${e.message}")
        e.printStackTrace()
    }
}

验证方法 #

确认代码修复后，你可以在Postgres客户端执行NOTIFY added_workspace_request, '测试消息';，查看控制台是否打印对应的接收日志即可验证功能是否正常。

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