直连模式参数回调功能抛异常

[cyfonly]

直连模式下，使用参数回调功能Consumer端会抛出以下异常：
Caused by: java.lang.IllegalStateException: Serialized class com.dubbo.callback.Consumer$1 must implement java.io.Serializable

[leiwei2094]

Missing implements java.io.Serializable?

[cyfonly]

public interface CallbackListener{
    void change(String msg);
}

public interface CallbackService {
    void addListener(String key, CallbackListener listener);
}

public class CallbackServiceImpl implements CallbackService{
    @Override
    public void addListener(String key, CallbackListener listener) {
        System.out.println("-------------Provider receive: key=" + key);
        listener.change("hehehehehe");
    }
}

public class Provider {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "classpath:callback_provider.xml" });
        context.start();
        System.in.read();
    }
}

public class Consumer {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:callback_consumer.xml");
        context.start();
        CallbackService callbackService = (CallbackService) context.getBean("callbackService");
        callbackService.addListener("Chenng", new CallbackListener() {
            @Override
            public void change(String msg) {
                System.out.println("============Consumer reveive:msg=" + msg);
            }
        });
    }
}

consumer.xml

   <dubbo:registry register="false"/>
   <dubbo:protocol name="dubbo" port="20880"/>
   <bean id="callbackService" class="com.dubbo.callback.CallbackServiceImpl" />
   <dubbo:service interface="com.dubbo.callback.CallbackService" ref="callbackService">
       <dubbo:method name="addListener">
           <dubbo:argument index="1" callback="true" type="com.dubbo.callback.CallbackListener"/>
       </dubbo:method>
   </dubbo:service>

provider.xml
<dubbo:reference id="callbackService" interface="com.dubbo.callback.CallbackService" url="dubbo://127.0.0.1:20880"/>

[chickenlj]

Caused by: java.lang.IllegalStateException: Serialized class com.dubbo.callback.Consumer$1 must implement java.io.Serializable

Callback class should never serialized and transfered to provider, it's only a signal for internal implementation to do some trick. You may have missed some configurations.

[chickenlj]

Just noticed you use peer to peer to invoke provider directly. I guess you missed some parameters for the target provider url.

[aqqwiyth]

直连的模式下客户端无法感知服务端是否开启了callback.
而使用注册中心的情况下服务端会把方法的callback写入到注册中心里面去, 客户端也会根据参数做自适应

所以直连模式下添加下面的参数可以实现

<dubbo:reference url="dubbo://127.0.0.1:20880/?addListener.1.callback=true" .....