使用Python浏览Avahi服务时丢失服务

Question

我需要一个类，能够给我提供当前可用的某种类型的avahi服务列表。为此，我在一个单独的线程中运行一个gobject.MainLoop()（第23-25行），并为我感兴趣的每个服务添加一个浏览器（第27、28行）。原则上，这个方法是可行的。

但我遇到的问题是，并不是总能获取到所有的服务。有时候能列出所有可用的服务，有时候一个都没有，有时候只显示几个。我猜测是因为浏览器在适当的信号连接之前就开始遍历服务（第36行），但我不知道该怎么解决这个问题。下面是一个简单的例子，展示了这个失败的情况。

我在网上看到的大多数例子（例如：停止Avahi服务并返回元素列表）都是在设置好浏览器和连接好信号后再运行MainLoop。然后，当收到“AllForNow”信号时，循环就结束了。但对我来说，这种方法不可行，因为浏览器应该持续运行，并监听新服务的添加或移除（这方面是可靠的，只是最开始的查询有问题）。

#!/usr/bin/python
import dbus
from dbus.mainloop.glib import DBusGMainLoop
import avahi
import gobject
import threading

gobject.threads_init()
dbus.mainloop.glib.threads_init()

class ZeroconfBrowser:
    def __init__(self):
        self.service_browsers = set()
        self.services = {}
        self.lock = threading.Lock()

        loop = DBusGMainLoop(set_as_default=True)
        self._bus = dbus.SystemBus(mainloop=loop)
        self.server = dbus.Interface(
                self._bus.get_object(avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER), 
                avahi.DBUS_INTERFACE_SERVER)

        thread = threading.Thread(target=gobject.MainLoop().run)
        thread.daemon = True
        thread.start()

        self.browse("_ssh._tcp")
        self.browse("_http._tcp")

    def browse(self, service):
        if service in self.service_browsers:
            return
        self.service_browsers.add(service)

        with self.lock:
            browser = dbus.Interface(self._bus.get_object(avahi.DBUS_NAME, 
                    self.server.ServiceBrowserNew(avahi.IF_UNSPEC, 
                            avahi.PROTO_UNSPEC, service, 'local', dbus.UInt32(0))),
                    avahi.DBUS_INTERFACE_SERVICE_BROWSER)

            browser.connect_to_signal("ItemNew", self.item_new)
            browser.connect_to_signal("ItemRemove", self.item_remove)
            browser.connect_to_signal("AllForNow", self.all_for_now)
            browser.connect_to_signal("Failure", self.failure)

    def resolved(self, interface, protocol, name, service, domain, host, 
            aprotocol, address, port, txt, flags):
        print "resolved", interface, protocol, name, service, domain, flags

    def failure(self, exception):
        print "Browse error:", exception

    def item_new(self, interface, protocol, name, stype, domain, flags):
        with self.lock:
            self.server.ResolveService(interface, protocol, name, stype,
                    domain, avahi.PROTO_UNSPEC, dbus.UInt32(0),
                    reply_handler=self.resolved, error_handler=self.resolve_error)

    def item_remove(self, interface, protocol, name, service, domain, flags):
        print "removed", interface, protocol, name, service, domain, flags

    def all_for_now(self):
        print "all for now"

    def resolve_error(self, *args, **kwargs):
        with self.lock:
            print "Resolve error:", args, kwargs

import time
def main():
    browser = ZeroconfBrowser()
    while True:
        time.sleep(3)
        for key, value in browser.services.items():
            print key, str(value)

if __name__ == '__main__':
    main()

网络服务多线程主循环信号连接浏览器 avahi 服务发现服务监听

使用Python浏览Avahi服务时丢失服务

1 个回答

源代码

输出结果

撰写回答