小爱同学调用本地jar -巴法云

本文通过巴发云注册mqtt服务并在小爱同学注册实现

为什么要用巴法云的 自然是因为他免费啦
1. 准备

1.1注册巴法云

1. https://cloud.bemfa.com/

复制代码

1.2 在巴法云上创建mqtt设备云




注意

• 主题名称 一开始最好是006结尾 不是数字小爱是不会识别的
  
  
• 点击昵称就可以直接修改并且昵称和你呼叫小爱是有关系的
  比如我的是电脑百度 我就告诉小爱 "打开电脑百度" 这时我写的jar就会获得一条消息 消息内容是"on"
  相反"关闭电脑百度" 消息内容就是是"off"
  

1.3 在小米手机上关联巴法云

• 打开米家app -> 我的 -> 连接其他平台 -> 添加自己的巴法云
  

1.4 验证

• 呼叫小爱同学 "打开"+你的昵称 我的就是"打开电脑百度"
  

2 构建springboot项目

主要是监听和发送巴法云的mqtt消息并分析所携带的值做对应的操作
同理使用mqtt的测试工具 或者 其他语言实现也可以 在此只演示Java
2.1 pom文件

1.         
2.         <dependency>
3.             <groupId>org.springframework.integration</groupId>
4.             <artifactId>spring-integration-mqtt</artifactId>
5.             <version>5.3.1.RELEASE</version>
6.         </dependency>

复制代码

2.2 增加一个文件就行

下面这一段只是监听用的也是我从网上摘下来的一段 链接的话.... 忘了

1. package com.c.bafa.config;
3. import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
4. import org.springframework.context.annotation.Bean;
5. import org.springframework.context.annotation.Configuration;
6. import org.springframework.integration.annotation.ServiceActivator;
7. import org.springframework.integration.channel.DirectChannel;
8. import org.springframework.integration.core.MessageProducer;
9. import org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory;
10. import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
11. import org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter;
12. import org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler;
13. import org.springframework.integration.mqtt.support.DefaultPahoMessageConverter;
14. import org.springframework.messaging.MessageChannel;
15. import org.springframework.messaging.MessageHandler;
17. import java.io.IOException;
19. @Configuration
20. public class MqttConfig {
22.     // 消费消息
24.     /**
25.      * 创建MqttPahoClientFactory，设置MQTT Broker连接属性，如果使用SSL验证，也在这里设置。
26.      * @return factory
27.      */
28.     @Bean
29.     public MqttPahoClientFactory mqttClientFactory() {
30.         DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
31.         MqttConnectOptions options = new MqttConnectOptions();
33.         // 设置代理端的URL地址，可以是多个
34.         options.setServerURIs(new String[]{"tcp://bemfa.com:9501"});
36.         factory.setConnectionOptions(options);
37.         return factory;
38.     }
40.     /**
41.      * 入站通道
42.      */
43.     @Bean
44.     public MessageChannel mqttInputChannel() {
45.         return new DirectChannel();
46.     }
48.     /**
49.      * 入站
50.      */
51.     @Bean
52.     public MessageProducer inbound() {
53.         // Paho客户端消息驱动通道适配器，主要用来订阅主题
54.         MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(巴法云控制台左上角 私钥,
55.                 mqttClientFactory(), 你的主题名称 我的是"xiaoc006");
56.         adapter.setCompletionTimeout(5000);
58.         // Paho消息转换器
59.         DefaultPahoMessageConverter defaultPahoMessageConverter = new DefaultPahoMessageConverter();
60.         // 按字节接收消息
61. //        defaultPahoMessageConverter.setPayloadAsBytes(true);
62.         adapter.setConverter(defaultPahoMessageConverter);
63.         adapter.setQos(1); // 设置QoS
64.         adapter.setOutputChannel(mqttInputChannel());
65.         return adapter;
66.     }
68.     @Bean
69.     // ServiceActivator注解表明：当前方法用于处理MQTT消息，inputChannel参数指定了用于消费消息的channel。
70.     @ServiceActivator(inputChannel = "mqttInputChannel")
71.     public MessageHandler handler() {
72.         return message -> {
73.             String payload = message.getPayload().toString();
75.             // byte[] bytes = (byte[]) message.getPayload(); // 收到的消息是字节格式
76.             String topic = message.getHeaders().get("mqtt_receivedTopic").toString();
78.             // 根据主题分别进行消息处理。
79.             if (topic.matches(".+/sensor")) { // 匹配：1/sensor
80.                 String sensorSn = topic.split("/")[0];
81.                 System.out.println("传感器" + sensorSn + ": 的消息： " + payload);
82.             } else if (topic.equals("collector")) {
83.                 System.out.println("采集器的消息：" + payload);
84.             } else if (topic.equals("xiaoc006")) {
85.                 System.out.println("通知我的消息：主题[" + topic  + "]，负载：" + payload);
86.             } else {
87.                 System.out.println("丢弃消息：主题[" + topic  + "]，负载：" + payload);
88.             }
90.             Runtime rt = Runtime.getRuntime();
91.             String url = "https://www.baidu.com/";
92.             try {
93.                 rt.exec("rundll32 url.dll,FileProtocolHandler " + url);
94.             } catch (IOException e) {
95.                 e.printStackTrace();
96.             }
98.         };
99.     }
101.     // 发送消息
103.     /**
104.      * 出站通道
105.      */
106.     @Bean
107.     public MessageChannel mqttOutboundChannel() {
108.         return new DirectChannel();
109.     }
111.     /**
112.      * 出站
113.      */
114.     @Bean
115.     @ServiceActivator(inputChannel = "mqttOutboundChannel")
116.     public MessageHandler outbound() {
118.         // 发送消息和消费消息Channel可以使用相同MqttPahoClientFactory
119.         MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler("publishClient", mqttClientFactory());
120.         messageHandler.setAsync(true); // 如果设置成true，即异步，发送消息时将不会阻塞。
121.         messageHandler.setDefaultTopic("command");
122.         messageHandler.setDefaultQos(1); // 设置默认QoS
124.         // Paho消息转换器
125.         DefaultPahoMessageConverter defaultPahoMessageConverter = new DefaultPahoMessageConverter();
127.         // defaultPahoMessageConverter.setPayloadAsBytes(true); // 发送默认按字节类型发送消息
128.         messageHandler.setConverter(defaultPahoMessageConverter);
129.         return messageHandler;
130.     }
132. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！