import org.fourthline.cling.registry.RegistryListener; //导入依赖的package包/类
public UpnpServiceImpl(RegistryListener... registryListeners) {
    this(new DefaultUpnpServiceConfiguration(), registryListeners);
}
 

import org.fourthline.cling.registry.RegistryListener; //导入依赖的package包/类
public DLNARouteProvider(Context context) {
	super(context);

	// Use custom logger
	org.eclipse.jetty.util.log.Log.setLog(new JettyAndroidLog());

	this.downloadService = (DownloadService) context;
	dlnaServiceConnection = new ServiceConnection() {
		@Override
		public void onServiceConnected(ComponentName name, IBinder service) {
			dlnaService = (AndroidUpnpService) service;
			dlnaService.getRegistry().addListener(registryListener = new RegistryListener() {
				@Override
				public void remoteDeviceDiscoveryStarted(Registry registry, RemoteDevice remoteDevice) {

				}

				@Override
				public void remoteDeviceDiscoveryFailed(Registry registry, RemoteDevice remoteDevice, Exception e) {
					// Error is displayed in log anyways under W/trieveRemoteDescriptors
				}

				@Override
				public void remoteDeviceAdded(Registry registry, RemoteDevice remoteDevice) {
					deviceAdded(remoteDevice);
				}

				@Override
				public void remoteDeviceUpdated(Registry registry, RemoteDevice remoteDevice) {
					deviceAdded(remoteDevice);
				}

				@Override
				public void remoteDeviceRemoved(Registry registry, RemoteDevice remoteDevice) {
					deviceRemoved(remoteDevice);
				}

				@Override
				public void localDeviceAdded(Registry registry, LocalDevice localDevice) {
					deviceAdded(localDevice);
				}

				@Override
				public void localDeviceRemoved(Registry registry, LocalDevice localDevice) {
					deviceRemoved(localDevice);
				}

				@Override
				public void beforeShutdown(Registry registry) {

				}

				@Override
				public void afterShutdown() {

				}
			});

			for (Device<?, ?, ?> device : dlnaService.getControlPoint().getRegistry().getDevices()) {
				deviceAdded(device);
			}
			if(searchOnConnect) {
				dlnaService.getControlPoint().search();
			}
		}

		@Override
		public void onServiceDisconnected(ComponentName name) {
			dlnaService = null;
			registryListener = null;
		}
	};

	if(!context.getApplicationContext().bindService(new Intent(context, AndroidUpnpServiceImpl.class), dlnaServiceConnection, Context.BIND_AUTO_CREATE)) {
		Log.e(TAG, "Failed to bind to DLNA service");
	}
}
 

import org.fourthline.cling.registry.RegistryListener; //导入依赖的package包/类
@Override
protected void listRootsInternal(Uri uri, IBinder binder, Bundle args) {
    Observable.using(
            mConnectionFactory,
            new Func1<UpnpServiceServiceConnection, Observable<List<org.opensilk.music.model.Container>>>() {
                @Override
                public Observable<List<org.opensilk.music.model.Container>> call(
                        final UpnpServiceServiceConnection upnpServiceServiceConnection) {
                    final AndroidUpnpService service = upnpServiceServiceConnection.getService();
                    return Observable.create(new Observable.OnSubscribe<List<org.opensilk.music.model.Container>>() {
                        @Override
                        public void call(final Subscriber<? super List<org.opensilk.music.model.Container>> subscriber) {
                            //first send all the devices we know about
                            List<org.opensilk.music.model.Container> devices = new ArrayList<>();
                            for (RemoteDevice rd : service.getRegistry().getRemoteDevices()) {
                                if (rd.findService(sCDServiceType) != null) {
                                    devices.add(ModelUtil.parseDevice(mAuthority, rd));
                                }
                            }
                            if (!devices.isEmpty() && !subscriber.isUnsubscribed()) {
                                subscriber.onNext(devices);
                            }
                            if (subscriber.isUnsubscribed()) {
                                return;
                            }
                            final RegistryListener listener = new DefaultRegistryListener() {
                                @Override
                                public void remoteDeviceAdded(Registry registry, RemoteDevice device) {
                                    if (device.findService(sCDServiceType) != null) {
                                        Folder f = ModelUtil.parseDevice(mAuthority, device);
                                        if (!subscriber.isUnsubscribed()) {
                                            subscriber.onNext(Collections.singletonList(
                                                    (org.opensilk.music.model.Container) f));
                                        }
                                    }
                                }
                            };
                            //make sure we remove our listener
                            subscriber.add(Subscriptions.create(new Action0() {
                                @Override
                                @DebugLog
                                public void call() {
                                    service.getRegistry().removeListener(listener);
                                }
                            }));
                            //post new devices as they come in
                            service.getRegistry().addListener(listener);
                            service.getControlPoint().search(
                                    new UDAServiceTypeHeader(sCDServiceType));
                        }
                    });
                }
            },
            mConnectionCloseAction
    ).subscribeOn(Schedulers.computation())
            .subscribe(new BundleableSubscriber<org.opensilk.music.model.Container>(binder));
}