伺服器回調客戶端

透過參數回呼從伺服器端呼叫客戶端邏輯

功能描述

參數回呼方法與呼叫本地回呼或監聽器相同，您只需要在 Spring 配置檔案中聲明哪個參數是回呼類型。Dubbo 會基於持久連接生成一個反向代理，以便可以從伺服器呼叫客戶端邏輯。您可以參考 dubbo 項目中的範例程式碼。

使用場景

回呼函數通知客戶端執行結果，或發送通知。當方法執行時間較長時，類似於非同步呼叫，並在審批工作流程中回呼客戶端審批結果。

如何使用

服務介面範例

CallbackService.java

package com. callback;
 
public interface CallbackService {
    void addListener(String key, CallbackListener listener);
}

CallbackListener.java

package com. callback;
 
public interface CallbackListener {
    void changed(String msg);
}

服務提供者介面實作範例

package com.callback.impl;
 
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
import com.callback.CallbackListener;
import com.callback.CallbackService;
 
public class CallbackServiceImpl implements CallbackService {
     
    private final Map<String, CallbackListener> listeners = new ConcurrentHashMap<String, CallbackListener>();
  
    public CallbackServiceImpl() {
        Thread t = new Thread(new Runnable() {
            public void run() {
                while(true) {
                    try {
                        for(Map.Entry<String, CallbackListener> entry : listeners.entrySet()){
                           try {
                               entry.getValue().changed(getChanged(entry.getKey()));
                           } catch (Throwable t) {
                               listeners. remove(entry. getKey());
                           }
                        }
                        Thread.sleep(5000); // Timely trigger change notification
                    } catch (Throwable t) { // defensive fault tolerance
                        t. printStackTrace();
                    }
                }
            }
        });
        t. setDaemon(true);
        t. start();
    }
  
    public void addListener(String key, CallbackListener listener) {
        listeners. put(key, listener);
        listener.changed(getChanged(key)); // send change notification
    }
     
    private String getChanged(String key) {
        return "Changed: " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
    }
}

服務提供者配置範例

<bean id="callbackService" class="com.callback.impl.CallbackServiceImpl" />
<dubbo:service interface="com.callback.CallbackService" ref="callbackService" connections="1" callbacks="1000">
    <dubbo:method name="addListener">
        <dubbo:argument index="1" callback="true" />
        <!--You can also specify the type -->
        <!--<dubbo:argument type="com.demo.CallbackListener" callback="true" />-->
    </dubbo:method>
</dubbo:service>

服務消費者配置範例

<dubbo:reference id="callbackService" interface="com.callback.CallbackService" />

服務消費者呼叫範例

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
context. start();
 
CallbackService callbackService = (CallbackService) context. getBean("callbackService");
 
callbackService.addListener("foo.bar", new CallbackListener(){
    public void changed(String msg) {
        System.out.println("callback1:" + msg);
    }
});

上次修改時間：2023 年 1 月 2 日：增強英文文件 (#1798) (95a9f4f6c1c)