@@ -81,7 +81,7 @@ public void tearDown() {
81
81
}
82
82
83
83
/**
84
- * 测试Zookeeper Provider Observer
84
+ * 测试 Nacos Provider Observer
85
85
*
86
86
* @throws Exception the exception
87
87
*/
@@ -93,21 +93,21 @@ public void testProviderObserver() throws Exception {
93
93
TimeUnit .SECONDS .sleep (10 );
94
94
95
95
serverConfig = new ServerConfig ()
96
- .setProtocol ("bolt" )
97
- .setHost ("0.0.0.0" )
98
- .setPort (12200 );
96
+ .setProtocol ("bolt" )
97
+ .setHost ("0.0.0.0" )
98
+ .setPort (12200 );
99
99
100
100
ProviderConfig <?> provider = new ProviderConfig ();
101
101
provider .setInterfaceId ("com.alipay.xxx.NacosTestService" )
102
- .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
103
- .setUniqueId ("nacos-test" )
104
- .setProxy ("javassist" )
105
- .setRegister (true )
106
- .setRegistry (registryConfig )
107
- .setSerialization ("hessian2" )
108
- .setServer (serverConfig )
109
- .setWeight (222 )
110
- .setTimeout (3000 );
102
+ .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
103
+ .setUniqueId ("nacos-test" )
104
+ .setProxy ("javassist" )
105
+ .setRegister (true )
106
+ .setRegistry (registryConfig )
107
+ .setSerialization ("hessian2" )
108
+ .setServer (serverConfig )
109
+ .setWeight (222 )
110
+ .setTimeout (3000 );
111
111
112
112
// 注册
113
113
try {
@@ -120,13 +120,13 @@ public void testProviderObserver() throws Exception {
120
120
121
121
ConsumerConfig <?> consumer = new ConsumerConfig ();
122
122
consumer .setInterfaceId ("com.alipay.xxx.NacosTestService" )
123
- .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
124
- .setUniqueId ("nacos-test" )
125
- .setProxy ("javassist" )
126
- .setSubscribe (true )
127
- .setSerialization ("java" )
128
- .setInvokeType ("sync" )
129
- .setTimeout (4444 );
123
+ .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
124
+ .setUniqueId ("nacos-test" )
125
+ .setProxy ("javassist" )
126
+ .setSubscribe (true )
127
+ .setSerialization ("java" )
128
+ .setInvokeType ("sync" )
129
+ .setTimeout (4444 );
130
130
131
131
// 订阅
132
132
CountDownLatch latch = new CountDownLatch (1 );
@@ -144,12 +144,12 @@ public void testProviderObserver() throws Exception {
144
144
// 订阅 错误的uniqueId
145
145
ConsumerConfig <?> consumerNoUniqueId = new ConsumerConfig ();
146
146
consumerNoUniqueId .setInterfaceId ("com.alipay.xxx.NacosTestService" )
147
- .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
148
- .setProxy ("javassist" )
149
- .setSubscribe (true )
150
- .setSerialization ("java" )
151
- .setInvokeType ("sync" )
152
- .setTimeout (4444 );
147
+ .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
148
+ .setProxy ("javassist" )
149
+ .setSubscribe (true )
150
+ .setSerialization ("java" )
151
+ .setInvokeType ("sync" )
152
+ .setTimeout (4444 );
153
153
latch = new CountDownLatch (1 );
154
154
MockProviderInfoListener wrongProviderInfoListener = new MockProviderInfoListener ();
155
155
wrongProviderInfoListener .setCountDownLatch (latch );
@@ -174,9 +174,9 @@ public void testProviderObserver() throws Exception {
174
174
latch = new CountDownLatch (2 );
175
175
providerInfoListener .setCountDownLatch (latch );
176
176
provider .getServer ().add (new ServerConfig ()
177
- .setProtocol ("bolt" )
178
- .setHost ("0.0.0.0" )
179
- .setPort (12201 ));
177
+ .setProtocol ("bolt" )
178
+ .setHost ("0.0.0.0" )
179
+ .setPort (12201 ));
180
180
registry .register (provider );
181
181
182
182
latch .await (timeoutPerSub * 2 , TimeUnit .MILLISECONDS );
@@ -189,13 +189,13 @@ public void testProviderObserver() throws Exception {
189
189
// 重复订阅
190
190
ConsumerConfig <?> consumer2 = new ConsumerConfig ();
191
191
consumer2 .setInterfaceId ("com.alipay.xxx.NacosTestService" )
192
- .setUniqueId ("nacos-test" )
193
- .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
194
- .setProxy ("javassist" )
195
- .setSubscribe (true )
196
- .setSerialization ("java" )
197
- .setInvokeType ("sync" )
198
- .setTimeout (4444 );
192
+ .setUniqueId ("nacos-test" )
193
+ .setApplication (new ApplicationConfig ().setAppName ("test-server" ))
194
+ .setProxy ("javassist" )
195
+ .setSubscribe (true )
196
+ .setSerialization ("java" )
197
+ .setInvokeType ("sync" )
198
+ .setTimeout (4444 );
199
199
CountDownLatch latch2 = new CountDownLatch (1 );
200
200
MockProviderInfoListener providerInfoListener2 = new MockProviderInfoListener ();
201
201
providerInfoListener2 .setCountDownLatch (latch2 );
@@ -214,17 +214,17 @@ public void testProviderObserver() throws Exception {
214
214
// 批量反注册,判断订阅者2的数据
215
215
latch = new CountDownLatch (2 );
216
216
providerInfoListener2 .setCountDownLatch (latch );
217
- List <ProviderConfig > providerConfigList = new ArrayList <ProviderConfig >();
217
+ List <ProviderConfig > providerConfigList = new ArrayList <>();
218
218
providerConfigList .add (provider );
219
219
registry .batchUnRegister (providerConfigList );
220
220
221
221
latch .await (timeoutPerSub * 2 , TimeUnit .MILLISECONDS );
222
- Assert .assertEquals ("after unregister: 1 " , 1 , ps2 .size ());
222
+ Assert .assertEquals ("after unregister: 0 " , 0 , ps2 .size ()); // 所有的 Provider 都已经反向注册了,应该是 0
223
223
224
224
LOGGER .info ("after unregister consumer, and consumer2 {}" , ps );
225
225
226
226
// 批量取消订阅
227
- List <ConsumerConfig > consumerConfigList = new ArrayList <ConsumerConfig >();
227
+ List <ConsumerConfig > consumerConfigList = new ArrayList <>();
228
228
consumerConfigList .add (consumer2 );
229
229
registry .batchUnSubscribe (consumerConfigList );
230
230
}
0 commit comments