看看构造函数，
1 //////////////////////////////////////////////// 2 // Constructor 3 //////////////////////////////////////////////// 4 5 public ControlPoint(int ssdpPort, int httpPort,InetAddress[] binds){ 6 ssdpNotifySocketList = new SSDPNotifySocketList(binds); 7 ssdpSearchResponseSocketList = new SSDPSearchResponseSocketList(binds); 8 9 setSSDPPort(ssdpPort); 10 setHTTPPort(httpPort); 11 12 setDeviceDisposer(null);//设置过期device清除接口，这儿为空 13 setExpiredDeviceMonitoringInterval(DEFAULT_EXPIRED_DEVICE_MONITORING_INTERVAL);//这儿有设置设备过期时间 14 15 setRenewSubscriber(null);//设置更新订购？ 不解ing 16 17 setNMPRMode(false);//NMPR模式是什么模式？ 18 setRenewSubscriber(null);//再设置一次？ 19 }
DLNA服务器列表的搜索开始于此文件中的start()接口，此接口实际上是调用start(ST.ROOT_DEVICE, SSDP.DEFAULT_MSEARCH_MX)。
1 //////////////////////////////////////////////// 2 // run 3 //////////////////////////////////////////////// 4 5 public boolean start(String target, int mx) 6 { 7 stop(); 8 9 //////////////////////////////////////// 10 // HTTP Server 11 //////////////////////////////////////// 12 //开启http server 并且试着绑定端口，如果失败，将继续 13 int retryCnt = 0; 14 int bindPort = getHTTPPort(); 15 HTTPServerList httpServerList = getHTTPServerList(); 16 while (httpServerList.open(bindPort) == false) { 17 retryCnt++; 18 if (UPnP.SERVER_RETRY_COUNT < retryCnt) 19 return false; 20 setHTTPPort(bindPort + 1); 21 bindPort = getHTTPPort(); 22 } 23 httpServerList.addRequestListener(this);//设置响应监听 24 httpServerList.start();//启动响应监听 25 26 //////////////////////////////////////// 27 // Notify Socket 28 //////////////////////////////////////// 29 //启动通知监听 30 SSDPNotifySocketList ssdpNotifySocketList = getSSDPNotifySocketList(); 31 if (ssdpNotifySocketList.open() == false) 32 return false; 33 ssdpNotifySocketList.setControlPoint(this); 34 ssdpNotifySocketList.start(); 35 36 //////////////////////////////////////// 37 // SeachResponse Socket 38 //////////////////////////////////////// 39 //启动搜索监听 40 int ssdpPort = getSSDPPort(); 41 retryCnt = 0; 42 SSDPSearchResponseSocketList ssdpSearchResponseSocketList = getSSDPSearchResponseSocketList(); 43 while (ssdpSearchResponseSocketList.open(ssdpPort) == false) { 44 retryCnt++; 45 if (UPnP.SERVER_RETRY_COUNT < retryCnt) 46 return false; 47 setSSDPPort(ssdpPort + 1); 48 ssdpPort = getSSDPPort(); 49 } 50 ssdpSearchResponseSocketList.setControlPoint(this); 51 ssdpSearchResponseSocketList.start(); 52 53 //////////////////////////////////////// 54 // search root devices 55 //////////////////////////////////////// 56 //搜索 57 search(target, mx); 58 59 //////////////////////////////////////// 60 // Disposer 61 //////////////////////////////////////// 62 //过期device处理 63 Disposer disposer = new Disposer(this); 64 setDeviceDisposer(disposer); 65 disposer.start(); 66 67 //////////////////////////////////////// 68 // Subscriber 69 //////////////////////////////////////// 70 //？？？？ 71 if (isNMPRMode() == true) { 72 RenewSubscriber renewSub = new RenewSubscriber(this); 73 setRenewSubscriber(renewSub); 74 renewSub.start(); 75 } 76 77 return true; 78 }
我们直接查看search接口:
1 public void search(String target, int mx) 2 { 3 SSDPSearchRequest msReq = new SSDPSearchRequest(target, mx);//设置搜索响应过滤条件 4 SSDPSearchResponseSocketList ssdpSearchResponseSocketList = getSSDPSearchResponseSocketList(); 5 ssdpSearchResponseSocketList.post(msReq); 6 }
查看SSDPSearchResponseSocketList.post
1 //////////////////////////////////////////////// 2 // Methods 3 //////////////////////////////////////////////// 4 5 public boolean post(SSDPSearchRequest req) 6 { 7 boolean ret = true; 8 int nSockets = size(); 9 for (int n=0; n<nSockets; n++) { 10 SSDPSearchResponseSocket sock = getSSDPSearchResponseSocket(n); 11 String bindAddr = sock.getLocalAddress(); 12 req.setLocalAddress(bindAddr); 13 String ssdpAddr = SSDP.ADDRESS; 14 if (HostInterface.isIPv6Address(bindAddr) == true) 15 ssdpAddr = SSDP.getIPv6Address(); 16 //sock.joinGroup(ssdpAddr, SSDP.PORT, bindAddr); 17 if (sock.post(ssdpAddr, SSDP.PORT, req) == false) 18 ret = false; 19 //sock.leaveGroup(ssdpAddr, SSDP.PORT, bindAddr); 20 } 21 return ret; 22 }