Android NSD项目代码

package com.nsd.lwx.nsddemo.activity; import android.content.Context; import android.net.nsd.NsdManager; import android.net.nsd.NsdServiceInfo; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.support.v7.app.AppCompatActivity; import android.util.Log; import android.view.View; import android.widget.AdapterView; import android.widget.ArrayAdapter; import android.widget.ListView; import android.widget.TextView; import android.widget.Toast; import com.nsd.lwx.nsddemo.R; import com.nsd.lwx.nsddemo.utils.Constant; import java.util.ArrayList; /** * nsd客户端页面 */ public class NSDClientActivity extends AppCompatActivity { /*NSD服务*/ private NsdManager mNsdManager = null; private NsdManager.DiscoveryListener mNSDDiscoveryListener = null; // 搜寻监听器 private NsdManager.ResolveListener mNSDResolveListener = null;// 解析监听器 private final String mServerType = Constant.SERVER_TYPE; private ArrayList<NsdServiceInfo> mNsdServiceInfoList0 = new ArrayList<>();//用来存储刚开始发现的网络对象列表，只有主机名字的数据 private ArrayList<NsdServiceInfo> mNsdServiceInfoList = new ArrayList<>();//用来存储解析后的网络对象列表，包含完整数据 private ArrayList<String> mServiceHostAddressList = new ArrayList<>();//用来区分是否重复的Host主机 private ArrayList<String> mServiceHostAddressAndNameList = new ArrayList<>();//用来显示给用户的列表信息 private TextView tv_connect_server; private ListView lv_server; private final String TAG = "NSDClientActivity"; private int mIndex = 0; private final int MSG_RESOLVER = 10; private boolean mStateServiceDiscoverying = false;//扫描主机状态 @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_nsd_client); initView(); initData(); initEvent(); } private void initView() { tv_connect_server = findViewById(R.id.tv_connect_server); lv_server = findViewById(R.id.lv_server); } private void initData() { mNsdManager = (NsdManager) getSystemService(Context.NSD_SERVICE); initNSDDiscoveryListener(); initNSDResolveListener(); } private void initEvent() { lv_server.setOnItemClickListener(new AdapterView.OnItemClickListener() { @Override public void onItemClick(AdapterView<?> parent, View view, int position, long id) { } }); } //注册NSD服务网络的监听，发现NSD网络后会在对应的方法回调 private void initNSDDiscoveryListener() { mNSDDiscoveryListener = new NsdManager.DiscoveryListener() { @Override public void onStartDiscoveryFailed(String serviceType, int errorCode) { Log.i(TAG, "onStartDiscoveryFailed--> " + serviceType + ":" + errorCode); } @Override public void onStopDiscoveryFailed(String serviceType, int errorCode) { Log.i(TAG, "onStopDiscoveryFailed--> " + serviceType + ":" + errorCode); } @Override public void onDiscoveryStarted(String serviceType) { Log.i(TAG, "onDiscoveryStarted--> " + serviceType); } @Override public void onDiscoveryStopped(String serviceType) { Log.i(TAG, "onDiscoveryStopped--> " + serviceType); } @Override public void onServiceFound(NsdServiceInfo serviceInfo) { mNsdServiceInfoList0.add(serviceInfo); Log.i(TAG, "Service Info: --> " + serviceInfo); //3秒后开始解析数据 if (mNsdServiceInfoList0.size() > 0) { mIndex = 0; mHandler.removeMessages(MSG_RESOLVER); mHandler.sendEmptyMessageDelayed(MSG_RESOLVER, 3 * 1000); } } @Override public void onServiceLost(NsdServiceInfo serviceInfo) { } }; } //注册解析NSD网络的监听 ,解析NSD数据后回调 private void initNSDResolveListener() { mNSDResolveListener = new NsdManager.ResolveListener() { @Override public void onResolveFailed(NsdServiceInfo serviceInfo, int errorCode) { } @Override public void onServiceResolved(NsdServiceInfo serviceInfo) { Log.i(TAG, "resolution : " + serviceInfo.getServiceName() + " \n host_from_server: " + serviceInfo.getHost() + "\n port from server: " + serviceInfo.getPort()); String hostAddress = serviceInfo.getHost().getHostAddress(); if (!mServiceHostAddressList.contains(hostAddress)) { mServiceHostAddressList.add(hostAddress); mServiceHostAddressAndNameList.add(hostAddress + ":" + serviceInfo.getPort() + " -- " + serviceInfo.getServiceName()); mNsdServiceInfoList.add(serviceInfo); } Log.i(TAG, "Service List--> " + mServiceHostAddressAndNameList); //继续解析数据 mHandler.sendEmptyMessageDelayed(MSG_RESOLVER, 10); } }; } private Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { super.handleMessage(msg); switch (msg.what) { case MSG_RESOLVER: if (mStateServiceDiscoverying) { mNsdManager.stopServiceDiscovery(mNSDDiscoveryListener); // 关闭网络发现 mStateServiceDiscoverying = false; } //开始根据ServiceName解析对应的 if (mIndex < mNsdServiceInfoList0.size()) { mNsdManager.resolveService(mNsdServiceInfoList0.get(mIndex), mNSDResolveListener); } else { //解析完成,显示出来啊 ArrayAdapter<String> adapter = new ArrayAdapter<String>(NSDClientActivity.this, android.R.layout.activity_list_item, android.R.id.text1, mServiceHostAddressAndNameList); lv_server.setAdapter(adapter); } mIndex++; break; } } }; //发现周边的NSD相关网络 public void discoveryNSDServer(View view) { if (mStateServiceDiscoverying) { Toast.makeText(this, "正在扫描网络...", Toast.LENGTH_SHORT).show(); } else { mNsdServiceInfoList0.clear(); mNsdServiceInfoList.clear(); mServiceHostAddressList.clear(); mServiceHostAddressAndNameList.clear(); mStateServiceDiscoverying = true; mNsdManager.discoverServices(mServerType, NsdManager.PROTOCOL_DNS_SD, mNSDDiscoveryListener); } } @Override protected void onDestroy() { super.onDestroy(); } }