一、两个Java的简单程序

1.1 给指定手机号码发送验证码

安装JDK、JRE和开发工具IntellJ IDEA 或Eclipse

代码

package com.kkb.demo;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.URL;import java.net.URLConnection;import java.net.URLEncoder;public class Demo5 {
   	public static void main(String[] args) throws IOException {
   		URL url = new URL("https://itdage.com/kkb/kkbsms?key=xzk&number=这里填手机号&code=这里填验证码");		URLConnection conn = url.openConnection();		InputStream is = conn.getInputStream();		BufferedReader br = new BufferedReader(new InputStreamReader(is,"UTF-8"));		String text = br.readLine();		System.out.println(text);		br.close();	}}

结果

在这里插入图片描述

1.2 读取指定城市的天气预报信息

package Weather;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.URL;import java.net.URLConnection;import java.net.URLEncoder;public class Weather_Report {
   		public static void main(String args[]) throws Exception {
   		weather();		email();	}		//获取天气信息	public static void weather() throws Exception{
   		//关键使用步骤：		//0.	将发送给图灵机器人的文字转化为URL编码		String question = URLEncoder.encode("重庆天气", "UTF-8");		//1. 	先准备一个URL类的对象 u		URL url = new URL("https://api.jisuapi.com/iqa/query?appkey=62958a3a6ef3c56d&question="+question);		//2. 	打开服务器连接，得到连接对象 conn		URLConnection conn = url.openConnection();		//3. 	获取加载数据的字节输入流 is		InputStream is = conn.getInputStream();		//4.	将is装饰为能一次读取一行的字符输入流 br		BufferedReader br = new BufferedReader(new InputStreamReader(is,"UTF-8"));		//5.	加载一行数据		String text = br.readLine();		//6.	显示		System.out.println(text);		//7.	释放资源		br.close();	}		//发送验证码	//number 是目标手机	//code 是验证码	public static void email() throws IOException{
           //关键使用步骤：  		//1. 	先准备一个URL类的对象 u  		URL url = new URL("https://itdage.com/kkb/kkbsms?key=xzk&number=***********&code=******");  		//2. 	打开服务器连接，得到连接对象 conn  		URLConnection conn = url.openConnection();  		//3. 	获取加载数据的字节输入流 is  		InputStream is = conn.getInputStream();  		//4.	将is装饰为能一次读取一行的字符输入流 br  		BufferedReader br = new BufferedReader(new InputStreamReader(is,"UTF-8"));  		//5.	加载一行数据  		String text = br.readLine();  		//6.	显示  		System.out.println(text);  		//7.	释放资源  		br.close();	}}

运行结果

在这里插入图片描述

二、MQTT

2.1 MQTT简介

MQTT（ Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（ publish/subscribe ）模式的 “ 轻量级 ” 通讯协议，该协议构建于 TCP/IP 协议上，由 IBM 在 1999 年发布。MQTT 最大优点在于，可以以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。作为一种低开销、低带宽占用的即时通讯协议，使其在物联网、小型设备、移动应用等方面有较广泛的应用。

MQTT 的特点：
MQTT 协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。其在，通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
MQTT 协议当前版本为，2014 年发布的 MQTT v3.1.1。除标准版外，还有一个简化版 MQTT-SN，该协议主要针对嵌入式设备，这些设备一般工作于 TCP/IP 网络，如：ZigBee。
MQTT 协议运行在 TCP/IP 或其他网络协议，提供有序、无损、双向连接。其特点包括：

使用的发布/订阅消息模式，它提供了一对多消息分发，以实现与应用程序的解耦；

对负载内容屏蔽的消息传输机制；

对传输消息有三种服务质量（QoS）：
——最多一次，这一级别会发生消息丢失或重复，消息发布依赖于底层TCP/IP网络。即：<=1；
——至多一次，这一级别会确保消息到达，但消息可能会重复。即：>=1；
——只有一次，确保消息只有一次到达。即：＝1。在一些要求比较严格的计费系统中，可以使用此级别；

数据传输和协议交换的最小化（协议头部只有2字节），以减少网络流量；

通知机制，异常中断时通知传输双方；

2.2 使用 apollo 搭建 MQTT 服务器

下载 apollo 链接：提取码：vy47
解压压缩包，然后用cmd进入到 apollo 下面的 bin 文件夹下，并使用命令 apollo.cmd create test，创建成功如下图所示。

在这里插入图片描述

开启 appllo 服务
使用 cmd 进入到 apache-apollo-1.7.1\bin\test\bin 路径下，运行命令 .\apollo-broker-service install 和 .\apollo-broker-service start 即可。

在这里插入图片描述

在服务里可以看到apollo服务开启

在这里插入图片描述

在 MQTT 服务器打开之后，选择 configration 下选择 apollo.xml 文件，修改 <host_name> 属性为服务器 ip(192.168.0.2)，<web_admin> 同步修改，以及 tcp 节点下将默认的 tcp://0.0.0.0:61613 修改为服务器的 ip，以供局域网使用，点击 Save 保存，即可在局域网内使用服务器的 ip 登录。