
IP属地:澳门
博主的意思实际就是在业务上进行拆分吧!
比如kafka中,单个partition是可以保证顺序的,但是单个线程消费太慢了。 所以将这个线程仅仅只做一层转发的功能,不做实际的业务功能。从parttion中取出数据然后根据规则,分发到不用的内存队列中。
比如:A-1,B-1,A-2,A-3,B-2。 实际上A、B是可以并行的。只需要在业务上区分即可。
如果你完全无法区分哪一组消息哪个可以并行,哪个不能并行。 那就没救了。只能老实排队一个个来。
关于MQ的几件小事(五)如何保证消息按顺序执行1.为什么要保证顺序 消息队列中的若干消息如果是对同一个数据进行操作,这些操作具有前后的关系,必须要按前后的顺序执行,否则就会造成数据异常。举例:比如通过mysql binl...