checkip.py 文件源码

def Server(self):
        self.Running = asyncio.Future()
        self.startindexIndex = self.ipfactory.getIndex()
        context = ssl.create_default_context()
        context.check_hostname = False

        if(not self.scan):
            self.loop.create_task(self.SaveIp())

        async with aiohttp.ClientSession(connector=aiohttp.TCPConnector(ssl_context=context, force_close=True),
                                         conn_timeout=0.7, read_timeout=0.8) as self.session:
            self.start_time = time.time()
            # print("create session Success")
            # print("startindex Scan Ip")
            while self._running:
                if self.now < self.max:
                    self.now += 1
                    # print("create task at", self.now)
                    # print("startindex Task Sum: ", self.now)
                    self.loop.create_task(self.worker())
                    if self.now == self.max:
                        self.future = asyncio.Future()
                else:
                    await self.future