import pro.beam.api.resource.channel.BeamChannel; //导入依赖的package包/类
/**
 * Connects a robot to a channel given an address to connect to and an authkey. This method blocks.
 *
 * @param info The credentials info object.
 * @param channel The channel to connect to.
 * @return A robot which is connected to the requested things. It will have been connected, set-up, and have
 * completed the handshake process by the time that it is returned.
 *
 * @throws IOException If the socket is unopenable, or becomes unreadable.
 */
protected Robot connectRobotTo(RobotInfo info, BeamChannel channel) throws IOException, InterruptedException {
    URI address = info.address.resolve("/robot");

    Robot robot = new Robot(address);
    robot.connect(info.key, channel);

    return robot;
}
 

import pro.beam.api.resource.channel.BeamChannel; //导入依赖的package包/类
/**
 * Connects to a given Channel on Beam, given an authkey. This authkey is supplied by the API.
 *
 * When this method is called, the socket is opened, and an IOException may be thrown. In addition,
 * the decoder task is prepared to be run on a new Thread in a concurrent fashion. Finally, a handshake
 * is sent down to the server.
 *
 * @param key The key to use when establishing a connection to the API.
 * @param channel The channel to connect to.
 * @throws IOException Thrown if the socket fails to establish itself, or closes itself.
 */
public void connect(String key, BeamChannel channel) throws IOException, InterruptedException {
    this.beginDecoding();
    this.connectBlocking();
    this.write(Handshaker.createHandshake(key, channel.id));
}