引言
近期需求，通过手机App端取号机(含叫号通知功能)，实时连接 另一台 Android 广告机用于播放当前被叫到的号数。
这里有两种Android 🐔
一台「基于Sunmi版的可出小票的Android🐔」
一台「Android系统 盒子连接上大屏电视 🐔」
总之要做的就是连接两台机子互相通讯，一台发送数据 一台处理展示。最终可实现两端互发！
基于项目整理奉献上一个 Demo，可直接进行使用。
本篇目录
1.寻找适合的通讯方式
2.NSD的作用和意义
3.关于NSD的开发的过程.
4.NSD Server 服务端的开发
5.NSD Client 客户端的开发
6.Netty 服务端的开发
7.Netty 客户端的开发
8.源码地址参考提示
1.寻找适合的通讯方式
使用 MQ 还是 Socket ？
了解下 MQ 和 Socket 的区别？ 下面这句话引用自百度某物联网产品经理：
" MQTT是为了物联网场景设计的基于TCP的Pub/Sub协议，有许多为物联网优化的特性，比如适应不同网络的QoS、层级主题、遗言等等。
WebSocket是为了HTML5应用方便与服务器双向通讯而设计的协议，HTTP握手然后转TCP协议，用于取代之前的Server Push、Comet、长轮询等老旧实现。两者之所有有交集，是因为一个应用场景：如何通过HTML5应用来作为MQTT的客户端，以便接受设备消息或者向设备发送信息，那么MQTT over WebSocket自然成了最合理的途径了。"
因为开始考虑 MQTT 适用于物联网之间的通讯，来实现通讯一些，后面考虑了稳定性和长连接性。还是决定用 Socket 来处理，Socket 考虑来找个轮子方便些。 使用了基于开源稳定的 「 Netty 」
基于Netty 又去找了个同样适用于应用到Android 的 「 NettyDemo 」，此 Demo 包含客户端、移动端（断线重连、心跳、黏包处理）可谓是非常合乎我想要的了。
通过 Socket 的话就必须预先通过 IP 和端口进行连接服务端，就必须知道服务端的地址。才能保证两端的连接 和通讯，让用户手动输入太繁琐了。后面发现Android 中有一个 NSD 服务，可以通过它来发现 预先通过 NSD 注册的服务端地址。真是太好了。
android NSD服务详解
NSD全称为: Network Service Discovery.翻译过来的意思就是发现服务器网络的意思。理解的说就是：发现服务器对应的网络信息。
2.NSD的作用和意义
NSD只是发现网络，并非直接连接网络，发现网络就是发现某个局域网内可连网络，并且获取到对应设备的IP地址和端口号。
NSD的作用就是为下一步连接网络做准备，比如使用Socket网络连接同一局域网两个手机，并且进行数据通信，这就要知道服务器的ip地址和端口号。
3.关于NSD的开发的过程.
NSD（NsdManager）是Android SDK中自带的类库，可以直接调用编程。
Tips: 使用 NSD服务 minSdkVersion >16
其实NSD和Socket有点类似，都是有Server服务器端和Client客户端
对于Socket：
SocketServer服务器端需要定义端口号，然后进行监听连接
SocketClient客户端需要知道服务器端定义的端口号和服务器的ip地址，然后请求连接
然后在客户端进行发送请求连接，服务器端同意连接，这时Socket连接就建立起来的，就可以相互通信了。
对于NSD：
NSD Server服务器端定义主机名字、端口号，然后进行NSD注册
NSD Client客户端进行扫描，但是只能扫描到包含NSD Server服务器定义的主机名字的NsdServiceInfo对象
然后NSD Client客户端能根据这个NsdServiceInfo对象解析到服务器端的IP地址和它的端口号
其实：NSD是为Socket连接做准备的其中一种手段！
4.NSD Server 服务端的开发
注册可被 NSD 所搜寻到的 服务端地址即可。这里使用封装过的，只指定名称和端口号
/**
* 服务器端注册一个可供NSD探测到的网络 Ip 地址，便于给展示叫号机连接此socket
*/
Runnable nsdServerRunnable = new Runnable() {
@Override
public void run() {
NSDServer nsdServer = new NSDServer();
nsdServer.startNSDServer(MainActivity.this, NSD_SERVER_NAME, NSD_PORT);
nsdServer.setRegisterState(new NSDServer.IRegisterState() {
@Override
public void onServiceRegistered(NsdServiceInfo serviceInfo) {
Log.i(TAG, "已注册服务onServiceRegistered: " + serviceInfo.toString());
//已经注册可停止该服务
// nsdServer.stopNSDServer();
}
@Override
public void onRegistrationFailed(NsdServiceInfo serviceInfo, int errorCode) {
}
@Override
public void onServiceUnregistered(NsdServiceInfo serviceInfo) {
}
@Override
public void onUnregistrationFailed(NsdServiceInfo serviceInfo, int errorCode) {
}
});
}
};
private void registerNsdServer() {
new Thread(nsdServerRunnable).start();
}
5.NSD Client 客户端的开发
通過 NSDClient 封装类 搜索註冊過的指定服務端名称的，回调 解析后拿到 IP 和端口 。然后可进行 Netty Socket 的连接。
/**
* 通過 Nsd 搜索註冊過的服務端名称 解析后拿到 IP 和端口 ，進行 NettySocket 的連接
*/
private void searchNsdServer() {
nsdClient = new NsdClient(MainActivity.this, SERVER_NAME, new NsdClient.IServerFound() {
@Override
public void onServerFound(NsdServiceInfo info, int port) {
if (info != null) {
String hostAddress = info.getHost().getHostAddress();
tvConnect.setText("NSD查询到指定服务器信息：\n" + info.toString());
//获取到指定的地址，进行Netty的连接
connectNettyServer(hostAddress, port);
if (info.getServiceName().equals(SERVER_NAME)) {
//掃描到對應後過後停止Nsd掃描
nsdClient.stopNSDServer();
}
}
}
@Override
public void onServerFail() {
}
});
nsdClient.startNSDClient();
}
6.Netty 服务端的开发
开启Socket 服务需要开启一个线程处理，等待客户端连接
/**
* 开启Socket 服务需要开启一个线程处理，等待客户端连接
*/
private void initNetty() {
if (!EchoServer.getInstance().isServerStart()) {
new NettyThread().start();
}
}
class NettyThread extends Thread {
@Override
public void run() {
super.run();
EchoServer.getInstance().setListener(new NettyListener() {
@Override
public void onMessageResponse(Object msg) {
Log.i(TAG, "Server received: " + (String) msg);
runOnUiThread(new Runnable() {
@Override
public void run() {
tvContent.setText("Server received: " + msg);
Toast.makeText(MainActivity.this, String.valueOf(msg), LENGTH_SHORT).show();
}
});
}
@Override
public void onChannel(Channel channel) {
//设置通道连接到封装的类中
EchoServer.getInstance().setChannel(channel);
Log.i(TAG, "建立连接 onChannel(): " + "接收(" + channel.toString() + ")");
runOnUiThread(new Runnable() {
@Override
public void run() {
tvNetty.setText("接收:(" + channel.toString() + ")");
}
});
}
@Override
public void onStartServer() {
Log.i(TAG, "Netty Server started 已开启");
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getApplicationContext(), "Netty Server 已開啟", LENGTH_SHORT).show();
}
});
}
@Override
public void onStopServer() {
Log.i(TAG, "Netty Server started 已开启");
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getApplicationContext(), "Netty Server 未連接", LENGTH_SHORT).show();
}
});
}
@Override
public void onServiceStatusConnectChanged(int statusCode) {
runOnUiThread(new Runnable() {
@Override
public void run() {
if (statusCode == NettyListener.STATUS_CONNECT_SUCCESS) {
Log.i(TAG, "STATUS_CONNECT_SUCCESS:");
//标记连接的状态
vOpenAppGetCode.setSelected(true);
} else {
Log.i(TAG, "onServiceStatusConnectChanged:" + statusCode);
tvNetty.setText("接收:");
vOpenAppGetCode.setSelected(false);
}
}
});
}
});
//入口 开启Netty Server
EchoServer.getInstance().start();
}
}
7.Netty 客户端的开发
根据 NSD 所搜寻到的指定服务器 IP 和 端口，进行连接。
/**
* 连接Netty 服务端
*
* @param host 服务端地址
* @param port 服务端端口 默认两端约定一致
*/
private void connectNettyServer(String host, int port) {
mNettyClient = new NettyClient(host, port);
Log.i(TAG, "connectNettyServer");
if (!mNettyClient.getConnectStatus()) {
mNettyClient.setListener(new NettyListener() {
@Override
public void onMessageResponse(Object msg) {
Log.i(TAG, "onMessageResponse:" + msg);
/**
* 接收服务端发送过来的 json数据解析
*/
// TODO: 2018/6/1 do something
// QueueShowBean queueShowBean = JSONObject.parseObject((String) msg, QueueShowBean.class);
//需要在主线程中刷新
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(MainActivity.this, msg + "", Toast.LENGTH_SHORT).show();
tvNetty.setText("Client received:" + msg);
}
});
}
@Override
public void onServiceStatusConnectChanged(int statusCode) {
/**
* 回调执行还在子线程中
*/
runOnUiThread(new Runnable() {
@Override
public void run() {
if (statusCode == NettyListener.STATUS_CONNECT_SUCCESS) {
Log.e(TAG, "STATUS_CONNECT_SUCCESS:");
vNettyStatus.setSelected(true);
} else {
Log.e(TAG, "onServiceStatusConnectChanged:" + statusCode);
vNettyStatus.setSelected(false);
}
}
});
}
});
mNettyClient.connect();//连接服务器
}
}
以上都是进行封装过的代码主要场景使用片段。
8.源码地址参考提示
参考项目：
封装类 NSD参考 android NSD 服务详解 他是搜索出所有的地址。而没有进行指定过滤。考虑到指定对应的连接的话，应该通过名称进行过滤本项目已针对修改。
关键的 Netty 使用全部参考 来自「 GitHub NettyDemo 」
这个 NettyDemo 非常棒和非常简洁的封装。实现了配置 （断线重连、心跳、黏包处理）
本项目地址 Github
Tips：
特别注意在Netty Channel 通道回调更新中是处于异步线程的，需要更新UI的操作需要执行在主线，否则你的这个Channel 会一直断开重连。写这个 本 Demo 的时候有踩了一上午坑，代码一摸一样，仅仅是在服务端 onMessageResponse（）方法中直接调用一个 View 去设置接收到到值，直接挂到，Channel 一直断线重连。主要是没注意到一行代码，自己到项目中是没问题。真的操练了一把低级得盲僧 瞎子闪现，- - 麻辣个鸡儿🐔
