Android 通过 NSD 服务 & Netty（断线

作者: thisfeng | 来源:发表于2018-06-01 16:48 被阅读494次

引言

近期需求，通过手机App端取号机(含叫号通知功能)，实时连接另一台 Android 广告机用于播放当前被叫到的号数。

这里有两种Android 🐔

一台「基于Sunmi版的可出小票的Android🐔」

一台「Android系统盒子连接上大屏电视 🐔」

总之要做的就是连接两台机子互相通讯，一台发送数据一台处理展示。最终可实现两端互发！
基于项目整理奉献上一个 Demo，可直接进行使用。

IMG20180601171657.jpg

本篇目录

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 一直断线重连。主要是没注意到一行代码，自己到项目中是没问题。真的操练了一把低级得盲僧瞎子闪现，- - 麻辣个鸡儿🐔

1527840976822.jpg

Android 通过 NSD 服务 & Netty（断线

引言

本篇目录

1.寻找适合的通讯方式

2.NSD的作用和意义

3.关于NSD的开发的过程.

4.NSD Server 服务端的开发

5.NSD Client 客户端的开发

6.Netty 服务端的开发

7.Netty 客户端的开发

8.源码地址参考提示

1.寻找适合的通讯方式

2.NSD的作用和意义

3.关于NSD的开发的过程.

对于Socket：

对于NSD：

4.NSD Server 服务端的开发

5.NSD Client 客户端的开发

6.Netty 服务端的开发

7.Netty 客户端的开发

8.源码地址参考提示

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读