search

microwww / redis-mock

redis server for java, java redis mock
https://github.com/microwww/jedis-mock
Apache License 2.0
47 stars 18 forks source link

Springboot subscribers in the same process cannot consume #8

Closed klaokai closed 1 year ago

klaokai commented 1 year ago

https://gitee.com/KyleLuo/SpringBoot-Labs.git

branch: comment

consumer: lab-11-spring-data-redis-unit-test producer:lab-11-spring-data-redis-mock

phenomenon:

2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [ SELECT-IO] com.github.microwww.redis.RedisServer : Ready [PUBLISH], request: 127.0.0.1:3416 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [ SELECT-IO] c.github.microwww.redis.database.Schema : Wait thread to run PUBLISH, 127.0.0.1:3416 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [pool-3-thread-1] c.github.microwww.redis.database.Schema : Get thread to run PUBLISH, 127.0.0.1:3416 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [pool-3-thread-1] c.g.m.r.p.operation.PubSubOperation : send subscribe TO 127.0.0.1:3255 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [pool-3-thread-1] c.g.m.r.p.operation.PubSubOperation : send subscribe TO 127.0.0.1:3273 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [ SELECT-IO] c.g.m.redis.protocal.RedisRequest : Flush PUBLISH outputStream 127.0.0.1:3416 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [ SELECT-IO] com.github.microwww.redis.RedisServer : Over [PUBLISH], request: 127.0.0.1:3416 2023-04-18T21:37:26.762+08:00 DEBUG 16688 --- [io-10809-exec-2] o.s.d.redis.core.RedisConnectionUtils : Closing Redis Connection

As you can see, the message was sent twice，but only consumer can consume。

lichangshu commented 1 year ago

You have two subscription servicer , the port is :3255, :3273

klaokai commented 1 year ago

You have two subscription servicer , the port is :3255, :3273

yes,because producer subscript it too.I can't see message log on it