有没有考虑过高并发的场景？消息堆积怎么办？消息丢失又怎么办？