camellia-delay-queue support use nacos as register center

[caojiajun]

Module: camellia-delay-queue
Content: support use nacos as register center

[firmianaQ]

请问现在的版本[1.2.28]有办法使用注册中心吗

[caojiajun]

当前支持eureka，其他注册中心需要简单开发一下

欢迎加入微信技术交流群

[firmianaQ]

当前支持eureka，其他注册中心需要简单开发一下

欢迎加入微信技术交流群

有示例吗？

[caojiajun]

服务器注册：
引入eureka依赖，配置发布即可

客户端发现：
实现DelayQueueServerDiscovery接口，在初始化CamelliaDelayQueueSdk时设置进去即可

参考：

public class EurekaDelayQueueServerDiscovery extends ReloadableCamelliaDiscovery<DelayQueueServer> implements DelayQueueServerDiscovery {

    private final DiscoveryClient discoveryClient;
    private final String applicationName;

    public EurekaDelayQueueServerDiscovery(DiscoveryClient discoveryClient, String applicationName, int refreshIntervalSeconds) {
        this.discoveryClient = discoveryClient;
        this.applicationName = applicationName;
        init(() -> new ArrayList<>(refreshProxySet()), refreshIntervalSeconds);
    }

    private Set<DelayQueueServer> refreshProxySet() {
        List<ServiceInstance> instances = discoveryClient.getInstances(applicationName);
        Set<DelayQueueServer> set = new HashSet<>();
        for (ServiceInstance instance : instances) {
            try {
                if (instance instanceof EurekaDiscoveryClient.EurekaServiceInstance) {
                    InstanceInfo instanceInfo = ((EurekaDiscoveryClient.EurekaServiceInstance) instance).getInstanceInfo();
                    if (instanceInfo.getStatus() != InstanceInfo.InstanceStatus.UP) {
                        continue;
                    }
                    set.add(new DelayQueueServer("http://" + instanceInfo.getIPAddr() + ":" + instanceInfo.getPort()));
                } else {
                    DelayQueueServer proxy = new DelayQueueServer("http://" + instance.getHost() + ":" + instance.getPort());
                    set.add(proxy);
                }
            } catch (Exception e) {
                DelayQueueServer proxy = new DelayQueueServer("http://" + instance.getHost() + ":" + instance.getPort());
                set.add(proxy);
            }
        }
        return set;
    }
}