66final class MainTestextends TestCase
77{
88
9- public function test ():void
9+ public function testSubscribe ():void
1010 {
1111$ funcfunction () {
1212$ subnew \Mix \Redis \Subscriber \Subscriber ('127.0.0.1 ' ,6379 ,'' ,5 );
@@ -31,6 +31,42 @@ public function test(): void
3131 }
3232break ;
3333 }
34+ $ this assertEquals ($ datachannel ,'foo1 ' );
35+ $ this assertEquals ($ datapayload ,'foo1data ' );
36+ break ;
37+ }
38+ $ subclose ();
39+ };
40+ run ($ func
41+ }
42+
43+ public function testPsubscribe ():void
44+ {
45+ $ funcfunction () {
46+ $ subnew \Mix \Redis \Subscriber \Subscriber ('127.0.0.1 ' ,6379 ,'' ,5 );
47+ $ subpsubscribe ('foo.* ' ,'bar ' );// 订阅失败将抛出异常
48+ $ subpsubscribe ('foo1.* ' ,'bar1 ' );
49+ $ subpunsubscribe ('foo.* ' ,'bar ' );
50+
51+ go (function () {
52+ $ redisnew \Redis ();
53+ $ redisconnect ('127.0.0.1 ' ,6379 );
54+ $ redispublish ('foo.1 ' ,'foodata ' );
55+ $ redispublish ('foo1.1 ' ,'foo1data ' );
56+ });
57+
58+ $ chan$ subchannel ();
59+ while (true ) {
60+ $ data$ chanpop ();
61+ if (empty ($ data// 手动close与redis异常断开都会导致返回false
62+ if (!$ subclosed ) {
63+ // redis异常断开处理
64+ var_dump ('Redis connection is disconnected abnormally ' );
65+ }
66+ break ;
67+ }
68+ $ this assertEquals ($ datapattern ,'foo1.* ' );
69+ $ this assertEquals ($ datachannel ,'foo1.1 ' );
3470$ this assertEquals ($ datapayload ,'foo1data ' );
3571break ;
3672 }