Удаленное управление сервером Raspberry Pi

4. Добавьте Device.javaфайл для установления MQTTсоединения.

public class Device {

    /**
     * Establish a connection
     * 
     * @param productKey: product key
     * @param deviceName: device name
     * @param deviceSecret: device secret
     * @throws InterruptedException
     */
    public static void connect(String productKey, String deviceName, String deviceSecret) throws InterruptedException {

        // Initialization parameters
        LinkKitInitParams params = new LinkKitInitParams();

        // Set MQTT initialization parameters
        IoTMqttClientConfig config = new IoTMqttClientConfig();
        config.productKey = productKey;
        config.deviceName = deviceName;
        config.deviceSecret = deviceSecret;
        params.mqttClientConfig = config;

        // Configure initialization device certificate information and pass the following:
        DeviceInfo deviceInfo = new DeviceInfo();
        deviceInfo.productKey = productKey;
        deviceInfo.deviceName = deviceName;
        deviceInfo.deviceSecret = deviceSecret;
        params.deviceInfo = deviceInfo;

        // Initialization
        LinkKit.getInstance().init(params, new ILinkKitConnectListener() {
            public void onError(AError aError) {
                System.out.println("init failed !! code=" + aError.getCode() + ",msg=" + aError.getMsg() + ",subCode="
                        + aError.getSubCode() + ",subMsg=" + aError.getSubMsg());
            }

            public void onInitDone(InitResult initResult) {
                System.out.println("init success !!") ;
            }
        });

        // Make sure that you perform the following steps only after the initialization is completed. You can adjust the latency as needed for this step
        Thread.sleep(2000);
    }

    /**
     * Publish messages
     * 
     * @param topic: the topic of the message to be sent
     * @param payload: the content of the message to be sent
     */
    public static void publish(String topic, String payload) {
        MqttPublishRequest request = new MqttPublishRequest();
        request.topic = topic;
        request.payloadObj = payload;
        request.qos = 0;
        LinkKit.getInstance().getMqttClient().publish(request, new IConnectSendListener() {
            @Override
            public void onResponse(ARequest aRequest, AResponse aResponse) {
            }

            @Override
            public void onFailure(ARequest aRequest, AError aError) {
            }
        });
    }

    /**
     * Subscribe to messages
     * 
     * @param topic: the topic of the subscribed message
     */
    public static void subscribe(String topic) {
        MqttSubscribeRequest request = new MqttSubscribeRequest();
        request.topic = topic;
        request.isSubscribe = true;
        LinkKit.getInstance().getMqttClient().subscribe(request, new IConnectSubscribeListener() {
            @Override
            public void onSuccess() {
            }

            @Override
            public void onFailure(AError aError) {
            }
        });
    }

    /**
     * Unsubscribe from messages
     * 
     * @param topic: the topic of the unsubscribed message
     */
    public static void unsubscribe(String topic) {
        MqttSubscribeRequest request = new MqttSubscribeRequest();
        request.topic = topic;
        request.isSubscribe = false;
        LinkKit.getInstance().getMqttClient().unsubscribe(request, new IConnectUnscribeListener() {
            @Override
            public void onSuccess() {
            }

            @Override
            public void onFailure(AError aError) {
            }
        });
    }

    /**
     * Disconnect
     */
    public static void disconnect() {
        // Deinitialize
        LinkKit.getInstance().deinit();
    }

}

public class SSHDevice {

    // ===================The list of required parameters begins here===========================
    // productKey
    private static String productKey = "";
    // 
    private static String deviceName = "";
    // deviceSecret
    private static String deviceSecret = "";
    // The topic of the communication message (You do not need to create or define one. It is directly available.)
    private static String rrpcTopic = "/sys/" + productKey + "/" + deviceName + "/rrpc/request/+";
    // The domain name or IP that SSH will access
    private static String host = "127.0.0.1";
    // SSH username
    private static String username = "";
    // SSH password
    private static String password = "";
    // SSH port number
    private static int port = 22;
    // ===================The list of required parameters ends here===========================

    public static void main(String[] args) throws InterruptedException {

        // Listen to downlink data
        registerNotifyListener();

        // Establish the connection
        Device.connect(productKey, deviceName, deviceSecret);

        // Subscribe to topics
        Device.subscribe(rrpcTopic);
    }

    public static void registerNotifyListener() {
        LinkKit.getInstance().registerOnNotifyListener(new IConnectNotifyListener() {
            @Override
            public boolean shouldHandle(String connectId, String topic) {
                // Only process messages with a specific topic
                if (topic.contains("/rrpc/request/")) {
                    return true;
                } else {
                    return false;
                }
            }

            @Override
            public void onNotify(String connectId, String topic, AMessage aMessage) {
                // Receive revert-RPC requests and return revert-RPC response
                try {
                    // Run remote commands
                    String payload = new String((byte[]) aMessage.getData(), "UTF-8");
                    SSHShell sshExecutor = new SSHShell(host, username, password, port);
                    sshExecutor.execute(payload);

                    // Obtain command echo
                    StringBuffer sb = new StringBuffer();
                    Vector<String> stdout = sshExecutor.getStdout();
                    for (String str : stdout) {
                        sb.append(str);
                        sb.append("\n");
                    }

                    // Return the echo to the server side
                    String response = topic.replace("/request/", "/response/");
                    Device.publish(response, sb.toString());
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }

            @Override
            public void onConnectStateChange(String connectId, ConnectState connectState) {
            }
        });
    }

}

<! -- Server-side SDK -->
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-iot</artifactId>
    <version>6.5.0</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.5.1</version>
</dependency>

<! -- commons-codec -->
<dependency>
    <groupId>commons-codec</groupId>
    <artifactId>commons-codec</artifactId>
    <version>1.8</version>
</dependency>

public class OpenApiClient {

    private static DefaultAcsClient client = null;

    public static DefaultAcsClient getClient(String accessKeyID, String accessKeySecret) {

        if (client ! = null) {
            return client;
        }

        try {
            IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKeyID, accessKeySecret);
            DefaultProfile.addEndpoint("cn-shanghai", "cn-shanghai", "Iot", "iot.cn-shanghai.aliyuncs.com");
            client = new DefaultAcsClient(profile);
        } catch (Exception e) {
            System.out.println("create Open API Client failed !! exception:" + e.getMessage());
        }

        return client;
    }

}

public class SSHCommandSender {

    // ===================The list of required parameters begins here===========================
    // User account AccessKey
    private static String accessKeyID = "";
    // User account AccesseKeySecret
    private static String accessKeySecret = "";
    // productKey
    private static String productKey = "";
    // deviceName
    private static String deviceName = "";
    // ===================The list of required parameters ends here===========================

    public static void main(String[] args) throws ServerException, ClientException, UnsupportedEncodingException {

        // Linux remote command
        String payload = "uname -a";

        // Build revert-RPC requests
        RRpcRequest request = new RRpcRequest();
        request.setProductKey(productKey);
        request.setDeviceName(deviceName);
        request.setRequestBase64Byte(Base64.encodeBase64String(payload.getBytes()));
        request.setTimeout(5000);

        // Obtain the server-side request client
        DefaultAcsClient client = OpenApiClient.getClient(accessKeyID, accessKeySecret);

        // Initiate a revert-RPC request
        RRpcResponse response = (RRpcResponse) client.getAcsResponse(request);

        // Process the revert-RPC response
        // response.getSuccess() indicates that the revert-RPC request is sent successfully. It does not indicate that the device has successfully received the request or that the response is successful.
        // Determination should be made based on RrpcCode. For more information, visit https://help.aliyun.com/document_detail/69797.html
        if (response ! = null && "SUCCESS".equals(response.getRrpcCode())) {
            // Echo
            System.out.println(new String(Base64.decodeBase64(response.getPayloadBase64Byte()), "UTF-8"));
        } else {
            // Echo fails and RrpcCode is printed
            System.out.println(response.getRrpcCode());
        }
    }

}