关于SpringMvc Zookeeper的问题 5C

我现在有一个SpringMvc的web项目。我现在的需求是监听zookeeper的节点变化。我需要怎么实现呢???

1

5个回答

你可以在配置文件里直接注册zk啊,然后在程序里面获取连接。
我的这个是dubbo和zk,配置

<dubbo:application name="${dubbo.service.name}" owner="Telematcis" organization="adt"/>

<!-- 使用zookeeper注册中心 -->
<dubbo:registry protocol="zookeeper" address="${zk.server}" timeout="30000"/>

<!--uncomment this if you want to test dubbo's monitor-->
<!--<dubbo:monitor protocol="registry"/>-->

<!-- 使用dubbo协议 -->

<!-- optimizer="com.adt.front.yang.rpc.protocol.SerializationOptimizerImpl"
extension="com.adt.framework.monitor.cat.dubbospi.DubboCatCrossFilter"
/>-->

<!-- 设定dubbo默认参数 -->
<dubbo:provider timeout="50000" retries="1" />
<dubbo:consumer timeout="50000" retries="1" />

    这里配置监听的RPC暴露的接口
     <dubbo:reference id="customerService"
                 interface="com.adt.service.yang.rpc.CustomerService" check="false" version="0.0.0.1"/>
0
qq_16873039
qq_16873039 用curator这个框架监听你要的节点,不管理删除,新增什么的 都会收到通知
一年多之前 回复
bobingling
bobingling 你可以在配置文件里直接注册zk啊,然后在程序里面获取连接
一年多之前 回复
ljl_90
ljl_90 等待高手 学习中
一年多之前 回复
qq_24715811
麻麻哈哈 这个我不知道
一年多之前 回复
ljl20169
BaidunJ 回复繁华穿越现实: 学习学习
一年多之前 回复
weixin_41496665
weixin_41496665 public class HelloZK { /** * Logger for this class */ private static final Logger logger = Logger.getLogger(HelloZK.class); private static final String CONNECTSTRING = "192.168.67.167:2181"; private static final String PATH = "/qqqq"; private static final int SESSION_TIMEOUT = 50*1000;
一年多之前 回复
qq_34701469
杨_5426 回复繁华穿越现实: 一个demo,java客户端操作zk的,不知道是不是你需要的
一年多之前 回复
dong_18383219470
繁华穿越现实 我不是使用dubbo,只是单纯的想实分布式环境下,配置文件同步。
一年多之前 回复

public class HelloZK
{
   /**
   * Logger for this class
   */
   private static final Logger logger = Logger.getLogger(HelloZK.class);
   
   private static final String CONNECTSTRING = "192.168.67.167:2181";
   private static final String PATH = "/qqqq";
   private static final int    SESSION_TIMEOUT = 50*1000;
   
   
   
   public ZooKeeper startZK() throws IOException
   {
       return new ZooKeeper(CONNECTSTRING, SESSION_TIMEOUT, new Watcher() {
          @Override
          public void process(WatchedEvent event)
          {
          }
       });
   }
   
   public void stopZK(ZooKeeper zk) throws InterruptedException
   {
       if(zk != null)
       {
          zk.close();
       }
   }
   
   public void createZNode(ZooKeeper zk,String path,String nodeValue) throws KeeperException, InterruptedException
   {
       zk.create(path,nodeValue.getBytes(),Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
   }
   
   public String getZNode(ZooKeeper zk,String path) throws KeeperException, InterruptedException
   {
       byte[] byteArray = zk.getData(path, false, new Stat());
       return new String(byteArray);
   }

   public static void main(String[] args) throws IOException, KeeperException, InterruptedException
   {
       HelloZK hello = new HelloZK();
       
       ZooKeeper zk = hello.startZK();
       
       Stat stat = zk.exists(PATH, false);
       
       if(stat == null)
       {
          hello.createZNode(zk, PATH, "zk1014");
          String result = hello.getZNode(zk, PATH);
          System.out.println("**********result: "+result);
       }else{
          System.out.println("***********znode has already ok***********");
       }
       
       hello.stopZK(zk);
   }
}
 

0
qq_34701469
杨_5426 回复繁华穿越现实: public ZooKeeper startZK() throws IOException    {        return new ZooKeeper(CONNECTSTRING, SESSION_TIMEOUT, new Watcher() {           @Override           public void process(WatchedEvent event)           {           }        });    }
一年多之前 回复
qq_34701469
杨_5426 回复繁华穿越现实: 你知道watch吗? zk监听,根据watch就知道zk的节点服务变动了
一年多之前 回复
dong_18383219470
繁华穿越现实 这个客户端我也有,也实现了NodeCacheListener接口,我现在是SpringMvc 如何监听zookeeper的状态变化。有点迷糊了。
一年多之前 回复

估计很难实现,没用过,不好意思

0

回复繁华穿越现实: 一个demo,java客户端操作zk的

0
0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
实战Dubbo与Zookeeper、SpringMVC整合使用
实战Dubbo与Zookeeper、SpringMVC整合使用 dubbo-admin-2.5.3.war CentOS 6.5 zookeeper-3.4.6.tar.gz jdk-7u25-linux-x64.gz Dubbo与Zookeeper、SpringMVC整合使用 1、zookeeper集群搭建 关于zookeeper集群搭建,可以参
分布式服务框架:zookeeper+dubbo+springmvc集成
Dubbo是一个分布式服务框架,在这基础上可以做成分布式计算机网络解决很多高并发或者数据处理量大的问题!二zookeeper又是dubbo的一个重要组件,在此,我借助java语言和springmvc框架介绍如何初步构建一个dubbo服务框架.   在liunx下部署zookeeper 问题排查: 首先说明一下本人的情况,我是启动zkServer.sh start 后显示是启动了,jps下也...
zookeeper+dubbo+springmvc项目整合
针对zookeeper+dubbo在maven项目中与springmvc进行整合
以zookeeper为注册中心springmvc集成dubbo的服务实现
一.创建一个web项目,作为dubbo的消费者 1.pom.xml<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 ht
Dubbo+Zookeeper+SpringMVC整合实现微服务项目
互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务架构以及流动计算架构势在必行,Dubbo是一个分布式服务框架,在这种情况下诞生的。现在核心业务抽取出来,作为独立的服务,使前端应用能更快速和稳定的响应。第一:介绍Dubbo背景    大规模服务化之前,应用可能只是通过RMI或Hessian等工具,简单的暴露和引用远程服务,通过配置服务的URL地址进行调用,通过F5等硬件...
zookeeper常见面试题
zookeeper是如何保证事务的顺序一致性的 zookeeper采用了递增的事务Id来标识,所有的proposal都在被提出的时候加上了zxid,zxid实际上是一个64位的数字,高32位是epoch用来标识leader是否发生改变,如果有新的leader产生出来,epoch会自增,低32位用来递增计数。当新产生proposal的时候,会依据数据库的两阶段过程,首先会向其他的server发出事
SpringMVC dubbo zookeeper
Springmvc dubbo zookeeper
dubbo zookeeper springmvc 集成
dubbo zookeeper springmvc 集成
Dubbo+Zookeeper+SpringMVC:基于注解的配置方法
一.环境说明 Windows 10 1709 JDK 1.8.0_144 IDEA 2017.3 Dubbo 2.5.7 Zookeeper 3.4.10 SpringMVC 4.3.12.RELEASE Maven 3.5.0 二.问题说明由于我的IDEA在使用xml配置式配置dubbo远程服务的时候,总是会报个红线,提示这个dubbo的服务bean不存在.虽然不影响运行与实际效果,但本着追求极致
dubbo/zookeeper/springMVC demo
一个简单的例子,集成dubbo/zookeeper/springMVC,(zookeeper伪集群)。
Dubbo+Zookeeper+SpringMVC整合实例
Dubbo与Zookeeper、SpringMVC整合使用。
Dubbo与Zookeeper、SpringMVC整合和使用
Dubbo与Zookeeper、SpringMVC整合和使用
dubbo spring zookeeper分布式集群搭建完整例子
使用springMVC + mysql +dubbo搭建的一个分布式简单例子,数据库大家可以自己创建一个,该用例可以直接运行,使用tomcat服务器运行即可
Dubbo与Zookeeper、SpringMVC整合与使用(干货-理论放一遍。。。还未完结!)
Dubbo跟Zookeeper的简介分享两个不错的链接: Dubbo简介:http://shiyanjun.cn/archives/325.html Zookeeper简介:http://www.open-open.com/lib/view/open1415453633887.html 说两句楼主自己的看法,我觉得身为一个java开发,原来自然是了解的好,但是我觉得先看简介不如从代码入手,然
ZooKeeper面试题
ZooKeeper面试题 1.ZooKeeper文件系统 Zookeeper提供一个多层级的节点命名空间(节点称为znode)。 与文件系统不同的是,这些节点都可以设置关联的数据,而文件系统中只有文件节点可以存放数据而目录节点不行。 Zookeeper为了保证高吞吐和低延迟,在内存中维护了这个树状的目录结构,这种特性使得Zookeeper不能用于存放大量的数据,每个节点的存放数据上限为1M。 2....
ZooKeeper学习总结(3)——ZooKeeper常见面试题
分享一个大神的人工智能教程。零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到人工智能的队伍中来!点击浏览教程 Zookeeper是什么框架 分布式的、开源的分布式应用程序协调服务,原本是Hadoop、HBase的一个重要组件。它为分布式应用提供一致性服务的软件,包括:配置维护、域名服务、分布式同步、组服务等。应用场景 Zookeeper的功能很强大,应用场景很多,结合我实际工作中使用Dub...
zookeeper面试题收集
Zookeeper集群中服务器之间是如何通信的 Follower与leader之间的通信主要是因为Follower接收到像(create, delete, setData, setACL, createSession, closeSession, sync)这样一些需要让leader来协调最终结果的命令,将会导致Follower与leader之间产生通信。由于leader与Follower之...
DUBBO分布式服务框架与SpringMVC+Zookeeper实现服务提供和消费
DUBBO是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,是阿里巴巴SOA服务化治理方案的核心框架,每天为2,000+个服务提供3,000,000,000+次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点。
Dubbo 集成 Zookeeper面试题整理
Dubbo 面试题整理: https://blog.csdn.net/Soinice/article/details/83858764 下面我为大家准备了一些 Dubbo 集成 Zookeeper 常见的的面试题,一些是我经常问别人的,一些是我过去面试遇到的一些问题,总结给大家,希望对大家能有所帮助。 1.Dubbo中zookeeper做注册中心,如果注册中心集群全都挂掉,发布者和订阅者之间...
zookeeper、dubbo整合搭建rpc(基于springMVC)
1、zookeeper1.1 安装jdk1.7 1.2 安装zookeeper 下载地址:http://zookeeper.apache.org/ 范例zookeeper版本:zookeeper-3.4.9 (官方稳定版本) 解压缩至根目录 1.2.1、并重新命名目录名称为“zoo”。 1.2.2、重命名C:\zoo\conf 下的“zoo_sample.cfg”文件为”zoo
spring和springMVC的面试问题总结
1.Spring中AOP的应用场景、Aop原理、好处? 答:AOP--Aspect Oriented Programming面向切面编程;用来封装横切关注点,具体可以在下面的场景中使用: Authentication 权限、Caching 缓存、Context passing 内容传递、Error handling 错误处理Lazy loading懒加载、Debugging调试、logging...
JAVA中的各种锁以及最优的zookeeper分布式锁解决方案
一、锁出现的原因-线程或者进程竞争资源当有一个或者多个线程或者进程进行操作时,其他线程或者进程都不可以对这个资源进行操作,直到该线程或者进程完成操作,其他线程或者进程才能对该资源进行操作,而其他线程或进程都处于等待状态。二、线程同步的方式和机制1、解决资源竞争问题(1)临界区:通过对多线程的串行化来来访问公共资源或者而一段代码Synchronized修饰的java方法(2)互斥量:采用互斥对象机制...
面试准备之solr集群及solr集群中zookeeper的应用和activeMQ
activeMQ应用场景:添加商品时需要将索引同步到数据库(这时候的manage-service充当消息的) solrcloud:solrcloud是solr提供的,基于solr和zookeeper的分布式搜索方案 应用场景 :1) 当需要大规模,容错,分布式索引和检索能力时使用solrcloud; 2)当索引量很大,搜索请求并发很高时,同样需要使用solrcloud来满足这些需求; 不过
Zookeeper集群的搭建及遇到的问题
一、Zookeeper集群的搭建1.准备三台主机mini1、mini2、mini3,安装Zookeeper:(1)导入Zookeeper-3.4.5.tar.gz安装包            直接拖安装包安装法: 前提,安装了lrzsz:也可以直接选:  (2)解包Zookeeper-3.4.5下不用的文件删除掉,否则运行时会很慢:最后剩下的文件为: 2. 配置文件为了不破坏zoo_samplle...
Dubbo与Zookeeper、SpringMVC整合和使用(负载均衡、容错)
互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务架构以及流动计算架构势在必行,Dubbo是一个分布式服务框架,在这种情况下诞生的。现在核心业务抽取出来,作为独立的服务,使前端应用能更快速和稳定的响应。
Dubbo+Zookeeper+SpringMVC整合实现分布式服务治理框架(附件含源码)
Dubbo是主流的采用RPC方式的分布式服务治理架构之一,实现了分布式服务注册、服务治理和服务监控等功能。通常需结合开源的Zookeeper、Redis或阿里数据库来完成注册中心的功能。
基于 Zookeeper 实现分布式锁
在我们进行单机应用开发,涉及并发同步的时候,我们往往采用 synchronized/Lock 方式来解决多线程间的代码同步问题。但当我们的应用是分布式部署的情况下,那么就需要一种更加高级的锁机制来处理这个进程级别的代码同步问题。那么接下来引出现在比较常用的几种分布式锁实现方案
dubbo整合springmvc,mybatis,redis,zookeeper,mysql
dubbo整合springmvc,mybatis,redis,zookeeper,mysql的简单demo
大数据开发面试部分:Zookeeper学习(大数据开发面试题)
Zookeeper学习: 什么是zookeeper? Zookeeper 是 Google 的 Chubby一个开源的实现,是 Hadoop 的分布式   协调  服务  service 包含一个简单的原语集,分布式应用程序可以基于它实现: 开源领域 首屈一指 zookeeper的特点: zookeeper的选举机制 刚开始启动: 以一个简单的例子来说明整个选举的过程. 假设有五...
springmvc+dubbo/zookeeper+activemq+redis+mybatis+druid
demo...springmvc+dubbo/zookeeper+activemq+redis+mybatis+druid
面试问题eureka和zookeeper的区别
作为服务注册中心,Eureka比Zookeeper好在哪里著名的CAP理论指出,一个分布式系统不可能同时满足C(一致性)、A(可用性)和P(分区容错性)。由于分区容错性在是分布式系统中必须要保证的,因此我们只能在A和C之间进行权衡。在此Zookeeper保证的是CP, 而Eureka则是AP。4.1 Zookeeper保证CP当向注册中心查询服务列表时,我们可以容忍注册中心返回的是几分钟以前的注册...
Dubbo+Zookeeper架构—持续集成篇11—Jenkins自动化部署:Jenkins中Maven和JDK配置
上一章介绍了如何安装Jenkins,这一章我们将介绍如何配置Jenkins的Maven和JDK环境 首先进入Maven和JDK配置页面 系统管理&amp;gt;全局工具配置 点击JDK安装 这里我们不选择在线安装,因为本地我已经装好Maven和JDK 所有我们把自动安装取消,选择手动安装,结果如下 JAVA_HOME:jdk安装路径 Maven安装同理          ...
学成在线教程资源分享
java 微服务教程资源,完整项目教程,spring,springboot,springmvc,zookeeper
zookeeper面试题
1.ZooKeeper是什么?ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终,将简单易用的接口和性能高效、功能稳定的系统提供给用户。客户端的读请求可以被集群中的任意一台机器处理,如果读请求在节点上注册了监听器,这个监听器也是由所连接的zookeep...
谈一谈你对zookeeper 的理解(大数据面试题系列~~)
文章目录Zookeeper 几个基本概念集群角色会话数据节点ZnodeWatcher 事件监听器几个典型应用场景Master 选举实现分布式锁用作微服务的注册中心 Apache Zookeeper 是由Apache Hadoop 的子项目发展而来,之后正式成为了Apache 的顶级项目。 Zookeeper 是一个典型的分布式数据一致性的解决方案,它 为分布式应用提供了高效可靠的分布式协调服务,分...
zookeeper资料
zookeeper资料 关于zookeeper的入门教程,java使用zookeeper的案例
(完整)maven多模块+springMVC+Mybatis(自动生成)+dubbo+Zookeeper
maven多模块+springMVC+Mybatis(自动生成)+dubbo+Zookeeper集成完整本地运行 maven库有些下载不下来可以删了手动下或者修改版本
分布式框架Zookeeper之服务注册与订阅
分布式框架Zookeeper之服务注册与订阅.........................
关于springmvc拦截静态资源的问题
当我们配置拦截器的url为&amp;lt;url-pattern&amp;gt;/&amp;lt;/url-pattern&amp;gt;时,这个是会访问不到静态资源的,如:js,css,图片等 &amp;lt;servlet&amp;gt; &amp;lt;servlet-name&amp;gt;taotao-sso-web&amp;lt;/servlet-name&amp;gt; &amp;lt;servlet-class&amp;gt;org...
Zookeeper分布式锁简单实现(JAVA)
近段时间尝试用可视化界面把zookeeper的数据集成到公司的后台系统中展示,进而查阅了资料研究zookeeper的使用,于是看着看着就手痒想用它的API实现一个简单的分布式锁. 本程序实现的分布式锁适用于集群单点故障,leader选举等场景 下面先从一下几个方面描述一下分布式锁的概述,问题及程序解决思路1. 概述分布式锁在一组进程之间提供了一种互斥机制。在任何时刻,在任何时刻只有一个进程可以
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 关于大数据培训 关于云计算