Przeglądaj źródła

dubbo的Callback不支持oninvoke
Echo回声应该对存在的服务进行强转

weihf 7 lat temu
rodzic
commit
2cc88d7bba

+ 3 - 3
ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/EchoServiceTest.java

@ -20,13 +20,13 @@ public class EchoServiceTest extends TestCase{
20 20
    /**
21 21
     * @author ThinkPad@asiainfo.com
22 22
     * @title: testEchoService
23
     * @desc: 回声测试可用性
23
     * @desc: 回声测试可用性,回声测试用于检测服务是否可用,用于监控
24 24
     */
25 25
    public void testEchoService() {
26 26
        // TODO Auto-generated method stub
27
        EchoService echoService = (EchoService)context.getBean("demoService"); 
27
        EchoService echoService = (EchoService)context.getBean("bizService"); 
28 28
        Object status = echoService.$echo("OK");
29
        System.out.println("demoService的服务状态:" + status);
29
        System.out.println("bizService的服务状态:" + status);
30 30
        assert(status.equals("OK"));
31 31
    }
32 32
}

+ 2 - 2
ipu-service-demo/src/test/resources/dubbo-consumer-simple.xml

@ -30,9 +30,9 @@
30 30
	<!-- 服务拦截 -->
31 31
	<bean id="serviceInterceptor" class="com.ai.ipu.service.demo.interceptor.ServiceInterceptor" />
32 32
	<dubbo:reference id="bizInterceptService" interface="com.ai.ipu.service.demo.IBizService">
33
		<dubbo:method name="queryUserInfo" oninvoke="serviceInterceptor.onInvoke"
33
		<dubbo:method name="queryUserInfo" 
34 34
			onreturn="serviceInterceptor.onReturn" />
35
		<dubbo:method name="triggerException" oninvoke="serviceInterceptor.onInvoke"
35
		<dubbo:method name="triggerException" 
36 36
			onthrow="serviceInterceptor.onThrow" async="true" />
37 37
	</dubbo:reference>
38 38
	<!-- 服务存根 -->