Java NotifyListener类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.alibaba.dubbo.registry.NotifyListener类的典型用法代码示例。如果您正苦于以下问题：Java NotifyListener类的具体用法？Java NotifyListener怎么用？Java NotifyListener使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

NotifyListener类属于com.alibaba.dubbo.registry包，在下文中一共展示了NotifyListener类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: subscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
public void subscribe(URL url, NotifyListener listener) {
    if (getUrl().getPort() == 0) {
        URL registryUrl = RpcContext.getContext().getUrl();
        if (registryUrl != null && registryUrl.getPort() > 0
        		&& RegistryService.class.getName().equals(registryUrl.getPath())) {
            super.setUrl(registryUrl);
            super.register(registryUrl);
        }
    }
    String client = RpcContext.getContext().getRemoteAddressString();
    ConcurrentMap<URL, Set<NotifyListener>> clientListeners = remoteSubscribed.get(client);
    if (clientListeners == null) {
        remoteSubscribed.putIfAbsent(client, new ConcurrentHashMap<URL, Set<NotifyListener>>());
        clientListeners = remoteSubscribed.get(client);
    }
    Set<NotifyListener> listeners = clientListeners.get(url);
    if (listeners == null) {
        clientListeners.putIfAbsent(url, new ConcurrentHashSet<NotifyListener>());
        listeners = clientListeners.get(url);
    }
    listeners.add(listener);
    super.subscribe(url, listener);
    subscribed(url, listener);
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:25，代码来源:SimpleRegistryService.java

示例2: notify

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
@Override
protected void notify(URL url, NotifyListener listener, List<URL> urls) {
    if (url == null) {
        throw new IllegalArgumentException("notify url == null");
    }
    if (listener == null) {
        throw new IllegalArgumentException("notify listener == null");
    }
    try {
    	doNotify(url, listener, urls);
    } catch (Exception t) {
        // 将失败的通知请求记录到失败列表，定时重试
        Map<NotifyListener, List<URL>> listeners = failedNotified.get(url);
        if (listeners == null) {
            failedNotified.putIfAbsent(url, new ConcurrentHashMap<NotifyListener, List<URL>>());
            listeners = failedNotified.get(url);
        }
        listeners.put(listener, urls);
        logger.error("Failed to notify for subscribe " + url + ", waiting for retry, cause: " + t.getMessage(), t);
    }
}

开发者ID:zhuxiaolei，项目名称:dubbo2，代码行数:22，代码来源:FailbackRegistry.java

示例3: testSubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
/**
 * Test method for
 * {@link com.alibaba.dubbo.registry.support.injvm.InjvmRegistry#subscribe(java.util.Map, com.alibaba.dubbo.registry.support.NotifyListener)}
 * .
 */
@Test
public void testSubscribe() {
    // verify lisener.
    final AtomicReference<URL> args = new AtomicReference<URL>();
    registry.subscribe(consumerUrl, new NotifyListener() {

        public void notify(List<URL> urls) {
            // FIXME assertEquals(MulticastRegistry.this.service, service);
            args.set(urls.get(0));
        }
    });
    assertEquals(serviceUrl.toFullString(), args.get().toFullString());
    Map<URL, Set<NotifyListener>> arg = registry.getSubscribed();
    assertEquals(consumerUrl, arg.keySet().iterator().next());

}

开发者ID:flychao88，项目名称:dubbocloud，代码行数:22，代码来源:MulticastRegistryTest.java

示例4: testNotifyOverride_notmatch

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
/**
 * 服务名称不匹配，不能override invoker
 * 服务名称匹配，服务版本号不匹配
 */
@Test
public void testNotifyOverride_notmatch() throws Exception{
    URL newRegistryUrl = registryUrl.addParameter(Constants.EXPORT_KEY, serviceUrl);
    Invoker<RegistryProtocolTest> invoker = new MockInvoker<RegistryProtocolTest>(RegistryProtocolTest.class, newRegistryUrl);
    Exporter<?> exporter = protocol.export(invoker);
    RegistryProtocol rprotocol = RegistryProtocol.getRegistryProtocol();
    NotifyListener listener = getListener(rprotocol);
    List<URL> urls = new ArrayList<URL>();
    urls.add(URL.valueOf("override://0.0.0.0/com.alibaba.dubbo.registry.protocol.HackService?timeout=100"));
    listener.notify(urls);
    assertEquals(true, exporter.getInvoker().isAvailable());
    assertEquals(null, exporter.getInvoker().getUrl().getParameter("timeout"));
    exporter.unexport();
    destroyRegistryProtocol();
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:20，代码来源:RegistryProtocolTest.java

示例5: testNotifyOverride_notmatch

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
/**
 * 服务名称不匹配，不能override invoker
 * 服务名称匹配，服务版本号不匹配
 */
@Test
public void testNotifyOverride_notmatch() throws Exception {
    URL newRegistryUrl = registryUrl.addParameter(Constants.EXPORT_KEY, serviceUrl);
    Invoker<RegistryProtocolTest> invoker = new MockInvoker<RegistryProtocolTest>(RegistryProtocolTest.class, newRegistryUrl);
    Exporter<?> exporter = protocol.export(invoker);
    RegistryProtocol rprotocol = RegistryProtocol.getRegistryProtocol();
    NotifyListener listener = getListener(rprotocol);
    List<URL> urls = new ArrayList<URL>();
    urls.add(URL.valueOf("override://0.0.0.0/com.alibaba.dubbo.registry.protocol.HackService?timeout=100"));
    listener.notify(urls);
    assertEquals(true, exporter.getInvoker().isAvailable());
    assertEquals(null, exporter.getInvoker().getUrl().getParameter("timeout"));
    exporter.unexport();
    destroyRegistryProtocol();
}

开发者ID:l1325169021，项目名称:github-test，代码行数:20，代码来源:RegistryProtocolTest.java

示例6: notify

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void notify(List<URL> urls) {
    if(urls == null || urls.isEmpty()) return;
    
    for (Map.Entry<URL, Set<NotifyListener>> entry : getSubscribed().entrySet()) {
        URL url = entry.getKey();
        
        if(! UrlUtils.isMatch(url, urls.get(0))) {
            continue;
        }
        
        Set<NotifyListener> listeners = entry.getValue();
        if (listeners != null) {
            for (NotifyListener listener : listeners) {
                try {
                    notify(url, listener, filterEmpty(url, urls));
                } catch (Throwable t) {
                    logger.error("Failed to notify registry event, urls: " +  urls + ", cause: " + t.getMessage(), t);
                }
            }
        }
    }
}

开发者ID:zhuxiaolei，项目名称:dubbo2，代码行数:23，代码来源:AbstractRegistry.java

示例7: registered

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void registered(URL url) {
    for (Map.Entry<URL, Set<NotifyListener>> entry : getSubscribed().entrySet()) {
        URL key = entry.getKey();
        if (UrlUtils.isMatch(key, url)) {
            Set<URL> urls = received.get(key);
            if (urls == null) {
                received.putIfAbsent(key, new ConcurrentHashSet<URL>());
                urls = received.get(key);
            }
            urls.add(url);
            List<URL> list = toList(urls);
            for (NotifyListener listener : entry.getValue()) {
                notify(key, listener, list);
                synchronized (listener) {
                    listener.notify();
                }
            }
        }
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:21，代码来源:MulticastRegistry.java

示例8: unsubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
public void unsubscribe(URL url, NotifyListener listener) {
    if (! Constants.ANY_VALUE.equals(url.getServiceInterface())
            && url.getParameter(Constants.REGISTER_KEY, true)) {
        unregister(url);
    }
    String client = RpcContext.getContext().getRemoteAddressString();
    Map<URL, Set<NotifyListener>> clientListeners = remoteSubscribed.get(client);
    if (clientListeners != null && clientListeners.size() > 0) {
        Set<NotifyListener> listeners = clientListeners.get(url);
        if (listeners != null && listeners.size() > 0) {
            listeners.remove(listener);
        }
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:15，代码来源:SimpleRegistryService.java

示例9: doSubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void doSubscribe(URL url, NotifyListener listener) {
    if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {
        admin = true;
    }
    broadcast(Constants.SUBSCRIBE + " " + url.toFullString());
    synchronized (listener) {
        try {
            listener.wait(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
        } catch (InterruptedException e) {
        }
    }
}

开发者ID:yunhaibin，项目名称:dubbox-hystrix，代码行数:13，代码来源:MulticastRegistry.java

示例10: unregistered

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void unregistered(URL url) {
    for (Map.Entry<URL, Set<NotifyListener>> entry : getSubscribed().entrySet()) {
        URL key = entry.getKey();
        if (UrlUtils.isMatch(key, url)) {
            List<URL> list = lookup(key);
            for (NotifyListener listener : entry.getValue()) {
            	listener.notify(list);
            }
        }
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:12，代码来源:SimpleRegistryService.java

示例11: unregistered

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void unregistered(URL url) {
    for (Map.Entry<URL, Set<NotifyListener>> entry : getSubscribed().entrySet()) {
        URL key = entry.getKey();
        if (UrlUtils.isMatch(key, url)) {
            Set<URL> urls = received.get(key);
            if (urls != null) {
                urls.remove(url);
            }
            List<URL> list = toList(urls);
            for (NotifyListener listener : entry.getValue()) {
                notify(key, listener, list);
            }
        }
    }
}

开发者ID:yunhaibin，项目名称:dubbox-hystrix，代码行数:16，代码来源:MulticastRegistry.java

示例12: doNotify

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
private void doNotify(String service, List<URL> urls) {
    notified.put(service, urls);
    List<NotifyListener> listeners = notifyListeners.get(service);
    if (listeners != null) {
        for (NotifyListener listener : listeners) {
            try {
                notify(service, urls, listener);
            } catch (Throwable t) {
                logger.error("Failed to notify registry event, service: " + service + ", urls: " +  urls + ", cause: " + t.getMessage(), t);
            }
        }
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:14，代码来源:AbstractRegistryService.java

示例13: addListener

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
private void addListener(final String service, final NotifyListener listener){
    if (listener == null) {
        return;
    }
    List<NotifyListener> listeners = notifyListeners.get(service);
    if (listeners == null) {
        notifyListeners.putIfAbsent(service, new CopyOnWriteArrayList<NotifyListener>());
        listeners = notifyListeners.get(service);
    }
    if (listeners != null && !listeners.contains(listener)){
        listeners.add(listener);
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:14，代码来源:AbstractRegistryService.java

示例14: removeListener

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
private void removeListener(final String service, final NotifyListener listener){
    if (listener == null) {
        return;
    }
    List<NotifyListener> listeners = notifyListeners.get(service);
    if (listeners != null) {
        listeners.remove(listener);
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:10，代码来源:AbstractRegistryService.java

示例15: doUnsubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void doUnsubscribe(URL url, NotifyListener listener) {
    ConcurrentMap<NotifyListener, ChildListener> listeners = zkListeners.get(url);
    if (listeners != null) {
        ChildListener zkListener = listeners.get(listener);
        if (zkListener != null) {
            zkClient.removeChildListener(toUrlPath(url), zkListener);
        }
    }
}

开发者ID:flychao88，项目名称:dubbocloud，代码行数:10，代码来源:ZookeeperRegistry.java

示例16: subscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
public void subscribe(URL url, NotifyListener listener) {
    this.subscribedUrl = url;
    List<URL> urls = new ArrayList<URL>();
    
    urls.add(url.setProtocol("mockprotocol")
                .removeParameter(Constants.CATEGORY_KEY)
                .addParameter(Constants.METHODS_KEY, "sayHello"));
    
    listener.notify(urls);
}

开发者ID:yunhaibin，项目名称:dubbox-hystrix，代码行数:11，代码来源:MockRegistry.java

示例17: testDoRetry_nofify

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
@Test
public void testDoRetry_nofify() throws Exception {

    //初始值0
    final AtomicInteger count = new AtomicInteger(0);

    NotifyListener listner = new NotifyListener() {
        public void notify(List<URL> urls) {
            count.incrementAndGet();
            //第一次抛出异常，看后面是否会再次调用到incrementAndGet
            if(count.get() == 1l ){
                throw new  RuntimeException("test exception please ignore");
            }
        }
    };
    registry = new MockRegistry(registryUrl, new CountDownLatch(0));
    registry.subscribe(serviceUrl.setProtocol(Constants.CONSUMER_PROTOCOL).addParameters(CollectionUtils.toStringMap("check", "false")), listner);

    assertEquals(1, count.get()); //确保subscribe调用完成后刚调用过一次count.incrementAndGet
    //等定时器.
    for (int i = 0; i < trytimes; i++) {
        System.out.println("failback notify retry ,times:" + i);
        if (count.get() == 2)
            break;
        Thread.sleep(sleeptime);
    }
    assertEquals(2, count.get());
}

开发者ID:zhuxiaolei，项目名称:dubbo2，代码行数:29，代码来源:FailbackRegistryTest.java

示例18: unsubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
@Override
public void unsubscribe(String service, URL url, NotifyListener listener) {
    super.unsubscribe(service, url, listener);
    String client = RpcContext.getContext().getRemoteAddressString();
    Map<String, NotifyListener> listeners = remoteListeners.get(client);
    if (listeners != null && listeners.size() > 0) {
        listeners.remove(service);
    }
    List<URL> urls = getRegistered().get(service);
    if (urls != null && urls.size() > 0) {
        listener.notify(urls);
    }
}

开发者ID:yunhaibin，项目名称:dubbox-hystrix，代码行数:14，代码来源:SimpleRegistryService.java

示例19: subscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
@Override
public void subscribe(URL url, NotifyListener listener) {
    super.subscribe(url, listener);
    removeFailedSubscribed(url, listener);
    try {
        // 向服务器端发送订阅请求
        doSubscribe(url, listener);
    } catch (Exception e) {
        Throwable t = e;

        List<URL> urls = getCacheUrls(url);
        if (urls != null && urls.size() > 0) {
            notify(url, listener, urls);
            logger.error("Failed to subscribe " + url + ", Using cached list: " + urls + " from cache file: " + getUrl().getParameter(Constants.FILE_KEY, System.getProperty("user.home") + "/dubbo-registry-" + url.getHost() + ".cache") + ", cause: " + t.getMessage(), t);
        } else {
            // 如果开启了启动时检测，则直接抛出异常
            boolean check = getUrl().getParameter(Constants.CHECK_KEY, true)
                    && url.getParameter(Constants.CHECK_KEY, true);
            boolean skipFailback = t instanceof SkipFailbackWrapperException;
            if (check || skipFailback) {
                if(skipFailback) {
                    t = t.getCause();
                }
                throw new IllegalStateException("Failed to subscribe " + url + ", cause: " + t.getMessage(), t);
            } else {
                logger.error("Failed to subscribe " + url + ", waiting for retry, cause: " + t.getMessage(), t);
            }
        }

        // 将失败的订阅请求记录到失败列表，定时重试
        addFailedSubscribed(url, listener);
    }
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:34，代码来源:FailbackRegistry.java

示例20: doUnsubscribe

import com.alibaba.dubbo.registry.NotifyListener; //导入依赖的package包/类
protected void doUnsubscribe(URL url, NotifyListener listener) {
    if (! Constants.ANY_VALUE.equals(url.getServiceInterface())
            && url.getParameter(Constants.REGISTER_KEY, true)) {
        unregister(url);
    }
    broadcast(Constants.UNSUBSCRIBE + " " + url.toFullString());
}

开发者ID:dachengxi，项目名称:EatDubbo，代码行数:8，代码来源:MulticastRegistry.java

注：本文中的com.alibaba.dubbo.registry.NotifyListener类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java NodeHeartbeatResponse类代码示例发布时间：2022-05-21

Java AccelDeviceEventListener类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：17925|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9552|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8120|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8500|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8403|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9291|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8367|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7796|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8350|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7354|2022-11-06

客服电话

电子邮件

Java NotifyListener类代码示例

示例1: subscribe

示例2: notify

示例3: testSubscribe

示例4: testNotifyOverride_notmatch

示例5: testNotifyOverride_notmatch

示例6: notify

示例7: registered

示例8: unsubscribe

示例9: doSubscribe

示例10: unregistered

示例11: unregistered

示例12: doNotify

示例13: addListener

示例14: removeListener

示例15: doUnsubscribe

示例16: subscribe

示例17: testDoRetry_nofify

示例18: unsubscribe

示例19: subscribe

示例20: doUnsubscribe

请发表评论

全部评论

上一篇：

下一篇：

PacktPublishing/Python-Machine-Learning-

kubernetes-up-and-running/kuard: Demo ap

sussillo/hfopt-matlab: A parallel, cpu-b

鲁东大学一米网:Win7系统USB驱动器RAM的操

emersion/go-ostatus: An OStatus library

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053