使用kcAdminClient与NestJS时遇Keycloak连接错误求助

我正在使用Keycloak，借助@keycloak/keycloak-admin-client包实现用户编辑功能，后端基于NestJS开发，以下是app.service.ts代码：

import { Injectable } from '@nestjs/common';
import KcAdminClient from '@keycloak/keycloak-admin-client';

@Injectable()
export class AppService {
  private adminClient: KcAdminClient;

  constructor() {
    this.getAdminProperties().then(admin => {
      this.adminClient = admin;
    })
  }

  async getAdminProperties() {
    const kcAdminClient = new KcAdminClient();

    await kcAdminClient.auth({
      username: 'user',
      password: 'user',
      grantType: 'password',
      clientId: 'admin-cli',
      
    });

    kcAdminClient.setConfig({
      realmName: 'space-realm',
    });    

    return kcAdminClient;
  }

  updateUser(body: any, id: number): any {
    this.adminClient.users.update({ id: id.toString() }, body)
  }
}

运行代码后出现如下错误：

(node:732) UnhandledPromiseRejectionWarning: Error: connect ECONNREFUSED 127.0.0.1:8080
at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1144:16)

(node:732) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). To terminate the node process on unhandled promise rejection, use the CLI flag --unhandled-rejections=strict. (rejection id: 2)

错误原因分析 #

• 缺少Keycloak服务器地址配置：@keycloak/keycloak-admin-client默认连接127.0.0.1:8080，如果你的Keycloak实例不在这个地址运行，必然触发连接拒绝错误。
• 异步初始化竞态问题：构造函数中用then延迟赋值adminClient，如果updateUser先于初始化完成调用，会导致this.adminClient为undefined。
• 未处理Promise异常：updateUser调用了返回Promise的users.update，但既没返回Promise也没捕获异常，引发未处理拒绝警告。

修复方案 #

修复后的完整代码 #

import { Injectable } from '@nestjs/common';
import KcAdminClient from '@keycloak/keycloak-admin-client';

@Injectable()
export class AppService {
  private adminClient: KcAdminClient;

  constructor() {
    this.initAdminClient();
  }

  private async initAdminClient() {
    try {
      // 初始化时指定Keycloak服务器地址，替换为你的实际地址
      this.adminClient = new KcAdminClient({
        baseUrl: 'http://your-keycloak-server:port',
      });

      await this.adminClient.auth({
        username: 'user',
        password: 'user',
        grantType: 'password',
        clientId: 'admin-cli',
        // 认证用的realm，默认是master，根据你的配置调整
        realm: 'master',
      });

      this.adminClient.setConfig({
        realmName: 'space-realm',
      });
    } catch (error) {
      console.error('Keycloak Admin Client初始化失败:', error);
      throw error; // 或根据业务需求处理初始化失败场景
    }
  }

  // 返回Promise，让调用方可以处理异常，同时校验客户端是否初始化完成
  async updateUser(body: any, id: number): Promise<void> {
    if (!this.adminClient) {
      throw new Error('Keycloak Admin Client尚未初始化完成');
    }
    await this.adminClient.users.update({ id: id.toString() }, body);
  }
}

额外注意事项 #

• 确认Keycloak服务正在运行，且baseUrl配置的地址、端口与实际部署一致。
• 确保认证用户拥有足够权限：在Keycloak的master realm中，给该用户分配realm-admin角色或具体的用户管理权限。
• 建议用NestJS的@nestjs/config将Keycloak配置（地址、用户名、密码等）存入环境变量，避免硬编码敏感信息。

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