│ WebSocket

 ▼

                            │

                            ▼

                       Windows RDP Server

/**
 * RDP管理
 *
 * @author zwmac
 */
@Slf4j
@RestController
@RequestMapping("/rdp")
public class RdpController {

    @Resource
    private GuacamoleRestService guacamoleRestService;

    /**
     * guacamole登錄
     *
     * @param rdpInfoVo 登錄信息
     * @return 登錄結(jié)果
     */
    @GetMapping("/login")
    public RestResponse<?> login(@RequestBody RdpInfoVo rdpInfoVo) {
        return guacamoleRestService.login(rdpInfoVo.getUsername(), rdpInfoVo.getPassword());
    }

    /**
     * 列出所有連接
     *
     * @param token 登錄token
     * @return 連接列表
     */
    @GetMapping("/listConnections")
    public RestResponse<?> listConnections(@RequestParam String token) {
        return guacamoleRestService.listConnections(token);
    }

    /**
     * 添加連接
     *
     * @param rdpConnectionInfoVo 連接信息
     * @return 添加結(jié)果
     */
    @PostMapping("/addConnection")
    public RestResponse<?> addConnection(@RequestBody RdpConnectionInfoVo rdpConnectionInfoVo) {
        return guacamoleRestService.addConnection(rdpConnectionInfoVo);
    }


}

/**
 * @author zwmac
 */
public interface GuacamoleRestService {
    /**
     * guacamole登錄
     *
     * @param username 用戶名
     * @param password 密碼
     * @return 登錄結(jié)果
     */
    RestResponse<?> login(String username, String password);

    /**
     * 列出所有連接
     *
     * @param token
     * @return
     */
    RestResponse<?> listConnections(String token);

    /**
     * 添加連接
     *
     * @param rdpConnectionInfoVo 連接信息
     * @return 添加結(jié)果
     */
    RestResponse<?> addConnection(RdpConnectionInfoVo rdpConnectionInfoVo);
}

/**
 * @author zwmac
 */
@Service
public class GuacamoleRestServiceImpl implements GuacamoleRestService {

    @Value("${guacamole.base-url}")
    private String guacamoleBaseUrl;

    @Value("${guacamole.datasource}")
    private String datasource;
    @Value("${guacamole.admin-user}")
    private String adminUserName;

    @Value("${guacamole.admin-password}")
    private String adminPassword;

    @Autowired
    private RestTemplate restTemplate;


    @Override
    public RestResponse<?> login(String username, String password) {
        if (StringUtils.isBlank(username) || StringUtils.isBlank(password)) {
            username = adminUserName;
            password = adminPassword;
        }
        Assert.isTrue(!StringUtils.isAnyBlank(username, password), "用戶名或密碼不能為空");

        Map<String, Object> formMap = new HashMap<>();
        formMap.put("username", username);
        formMap.put("password", password);
        HttpRequest post = HttpUtil.createPost(guacamoleBaseUrl + "/tokens");
        post.form(formMap);
        post.header("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
        HttpResponse execute = post.execute();
        if (execute.isOk()) {
            String executeBody = execute.body();
            return RestResponse.success(executeBody);
        }

        return RestResponse.fail("登錄失?。? + execute.body());
    }

    @Override
    public RestResponse<?> listConnections(String token) {
        Assert.hasText(token, "token不能為空");
        String getUrl = guacamoleBaseUrl + "/session/data/" + datasource + "/connections?token=" + token;
        HttpRequest get = HttpUtil.createGet(getUrl);
        HttpResponse execute = get.execute();
        if (execute.isOk()) {
            String executeBody = execute.body();
            return RestResponse.success(executeBody);
        }
        return RestResponse.fail("獲取連接列表失敗：" + execute.body());
    }

    @Override
    public RestResponse<?> addConnection(RdpConnectionInfoVo rdpConnectionInfoVo) {
        //參數(shù)校驗
        Assert.notNull(rdpConnectionInfoVo, "參數(shù)不能為空");

        return null;
    }
}

guacamole:
  base-url: http://你的guacamole部署ip:端口/guacamole/api
  datasource: mysql   # 對應(yīng) guacamole.properties 里的配置
  admin-user: guacadmin
  admin-password: guacadmin