参数回调

服务接口示例

CallbackService.java
CallbackListener.java
  1. void changed(String msg);
  2. }

服务提供者接口实现示例

服务提供者配置示例

  1. <bean id="callbackService" class="com.callback.impl.CallbackServiceImpl" />
  2. <dubbo:service interface="com.callback.CallbackService" ref="callbackService" connections="1" callbacks="1000">
  3. <dubbo:argument index="1" callback="true" />
  4. <!--也可以通过指定类型的方式-->
  5. <!--<dubbo:argument type="com.demo.CallbackListener" callback="true" />-->
  6. </dubbo:method>

服务消费者配置示例

服务消费者调用示例

  1. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
  2. CallbackService callbackService = (CallbackService) context.getBean("callbackService");
  3. callbackService.addListener("http://10.20.160.198/wiki/display/dubbo/foo.bar", new CallbackListener(){
  4. public void changed(String msg) {
  5. System.out.println("callback1:" + msg);

  • 2.0.6 及其以上版本支持