when my redis is crash.pub,sub will not reactivate

[larryclean]

Hi @miguelgrinberg !
when my redis is crash.pub,sub will not reactivate.
i try repair in asyncio_redis_manage.py.
The following code：

    async def _publish(self, data):

        if self.pub is None:
            self.pub = await aioredis.create_redis((self.host, self.port),
                                                   db=self.db,
                                                   password=self.password)
        try:
            await self.pub.ping()
        except:
            self.pub = await aioredis.create_redis((self.host, self.port),
                                                   db=self.db,
                                                   password=self.password)
        return await self.pub.publish(self.channel, pickle.dumps(data))

    async def _listen(self):
        if self.sub is None:
            self.sub = await aioredis.create_redis((self.host, self.port),
                                                   db=self.db,
                                                   password=self.password)
            self.ch = (await self.sub.subscribe(self.channel))[0]

        while True:
            try:
                return await self.ch.get()
            except:
                value=True
                while value:
                    try:
                        self.sub = await aioredis.create_redis((self.host, self.port),
                                                               db=self.db,
                                                               password=self.password)
                        value=False
                    except:
                        pass
                self.ch = (await self.sub.subscribe(self.channel))[0]
                return await self.ch.get()

[miguelgrinberg]

I'll look into this. The generic except clauses need to be made more specific, but I think I understand what problem is anyway.

[larryclean]

When my redis server is suspended, restart success will not receive pub information again.

[miguelgrinberg]

@Larry-Dev can I ask you to test the master branch of this package and let me know if your problems with reconnecting to redis are addressed?