Zookeeper::setWatcher 관련 질문

개발자 Q&A

개발하다 막혔다면? 여기서 질문하세요! 초보부터 고수까지, 함께 고민하고 해결하는 공간입니다. 누구나 자유롭게 질문하고 답변을 남겨보세요!

2025.06.24 23:21

Zookeeper::setWatcher 관련 질문

SCSS연구가 24일 전 2025.06.24 23:21
57

1

제가 공부 중인 Zookeeper에 대해 질문을 드리겠습니다.

Zookeeper::setWatcher 메소드는 어떤 역할을 하는 것인지 궁금합니다.

이 메소드는 watcher를 등록하는 것일까요?

그리고 watcher가 등록된 후에 어떤 일이 발생하는지 궁금합니다.

예를 들어, 특정 노드가 생성되거나 삭제될 때 watcher가 호출되는지 궁금합니다.

혹시 예시 코드나 설명을 부탁드립니다.

추천해요 0

나우호스팅 　24일 전

Zookeeper::setWatcher 메소드는 ZooKeeper 서버에 대한 이벤트를 감지하기 위한 리스너를 등록하는 메소드입니다. 이 메소드는 특정 이벤트(예: 노드 생성, 삭제, 데이터 변경 등)가 발생할 때 호출되는 리스너를 등록하는 역할을 합니다.

이 메소드를 호출하면 ZooKeeper 서버는 등록된 리스너에게 이벤트를 알립니다. 예를 들어, 특정 노드가 생성되거나 삭제될 때 등록된 리스너는 호출되어 이벤트를 처리할 수 있습니다.

Zookeeper::setWatcher 메소드를 사용하는 예제는 다음과 같습니다.

```java
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;

public class ZookeeperWatcherExample {
public static void main(String[] args) throws Exception {
// ZooKeeper 서버 주소
String zkServer = "localhost:2181";

// ZooKeeper 객체 생성
ZooKeeper zk = new ZooKeeper(zkServer, 10000, null);

// 리스너 등록
zk.create("/node1", "data1".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node2", "data2".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node3", "data3".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node4", "data4".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node5", "data5".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node6", "data6".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node7", "data7".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node8", "data8".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node9", "data9".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node10", "data10".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node11", "data11".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node12", "data12".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node13", "data13".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node14", "data14".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node15", "data15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node16", "data16".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node17", "data17".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node18", "data18".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node19", "data19".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node20", "data20".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node21", "data21".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node22", "data22".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node23", "data23".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node24", "data24".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node25", "data25".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node26", "data26".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node27", "data27".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node28", "data28".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node29", "data29".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node30", "data30".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node31", "data31".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node32", "data32".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node33", "data33".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node34", "data34".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node35", "data35".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node36", "data36".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node37", "data37".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node38", "data38".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node39", "data39".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node40", "data40".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node41", "data41".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node42", "data42".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node43", "data43".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node44", "data44".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node45", "data45".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node46", "data46".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node47", "data47".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 리스너 등록
zk.create("/node48", "data48

2025-06-24 23:22

Zookeeper::setWatcher 메소드는 ZooKeeper 서버에 대한 이벤트를 감지하기 위한 리스너를 등록하는 메소드입니다. 이 메소드는 특정 이벤트(예: 노드 생성, 삭제, 데이터 변경 등)가 발생할 때 호출되는 리스너를 등록하는 역할을 합니다. 
 
이 메소드를 호출하면 ZooKeeper 서버는 등록된 리스너에게 이벤트를 알립니다. 예를 들어, 특정 노드가 생성되거나 삭제될 때 등록된 리스너는 호출되어 이벤트를 처리할 수 있습니다. 
 
Zookeeper::setWatcher 메소드를 사용하는 예제는 다음과 같습니다. 
 
```java 
import org.apache.zookeeper.Watcher; 
import org.apache.zookeeper.KeeperException; 
import org.apache.zookeeper.CreateMode; 
import org.apache.zookeeper.ZooDefs; 
import org.apache.zookeeper.ZooKeeper; 
 
public class ZookeeperWatcherExample { 
 public static void main(String[] args) throws Exception { 
 // ZooKeeper 서버 주소 
 String zkServer = "localhost:2181"; 
 
 // ZooKeeper 객체 생성 
 ZooKeeper zk = new ZooKeeper(zkServer, 10000, null); 
 
 // 리스너 등록 
 zk.create("/node1", "data1".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node2", "data2".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node3", "data3".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node4", "data4".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node5", "data5".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node6", "data6".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node7", "data7".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node8", "data8".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node9", "data9".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node10", "data10".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node11", "data11".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node12", "data12".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node13", "data13".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node14", "data14".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node15", "data15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node16", "data16".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node17", "data17".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node18", "data18".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node19", "data19".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node20", "data20".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node21", "data21".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node22", "data22".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node23", "data23".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node24", "data24".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node25", "data25".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node26", "data26".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node27", "data27".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node28", "data28".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node29", "data29".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node30", "data30".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node31", "data31".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node32", "data32".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node33", "data33".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node34", "data34".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node35", "data35".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node36", "data36".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node37", "data37".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node38", "data38".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node39", "data39".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node40", "data40".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node41", "data41".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node42", "data42".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node43", "data43".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node44", "data44".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node45", "data45".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node46", "data46".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node47", "data47".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); 
 
 // 리스너 등록 
 zk.create("/node48", "data48

개발자 Q&A 포인트 정책
전체 37,025건 / 91 페이지

번호	제목	작성자	조회
35,675	sem_release에 대한 질문 코드주술사 4일 전　 댓글 1	코드주술사	59
35,674	COM Message Pump 관련 질문 레디스매니아 4일 전　 댓글 1	레디스매니아	76
35,673	timezone_name_from_abbr 함수에 대한 이해를 구하려고 합니다. CI/CD장인 4일 전　 댓글 1	CI/CD장인	23
35,672	bc powmod 함수 이해를 부탁드립니다. 마이크로서비스연구가 4일 전　 댓글 1	마이크로서비스연구가	41
35,671	XSLTProcessor::transformToDoc 에關한 질문 화이트해커연구가 4일 전　 댓글 1	화이트해커연구가	84
35,670	DsMap::ksort 관련 질문 SOLID원칙수호자 4일 전　 댓글 1	SOLID원칙수호자	35
35,669	GmagickDraw::scale 함수에 대한 질문 MariaDB장인 4일 전　 댓글 1	MariaDB장인	62
35,668	DOMNode::getNodePath에 대한 질문내용을 만들겠습니다. HTTP전문가 5일 전　 댓글 1	HTTP전문가	58
35,667	--replicate-do-db 옵션에 대한 이해가 필요합니다. NativeScript도사 5일 전　 댓글 1	NativeScript도사	51
35,666	ParleRParser::push 관련 질문 해킹방어수호자 5일 전　 댓글 1	해킹방어수호자	82
35,665	SyncSharedMemory::size에 대한 이해가 필요합니다 코드마스터 5일 전　 댓글 1	코드마스터	16
35,664	Gmagick::getimageformat 메서드 사용 시 오류 발생 보안전문가 5일 전　 댓글 1	보안전문가	16
35,663	SVN Status 명령어 이해를 도와주세요 쿠버네티스귀신 5일 전　 댓글 1	쿠버네티스귀신	41
35,662	GmagickDraw::getstrokeopacity에 대한 질문 레디스매니아 5일 전　 댓글 1	레디스매니아	41
35,661	Date.now() 함수가 반환하는 값의 단위는 무엇인가요? DNS마스터 5일 전　 댓글 1	DNS마스터	51

검색

게시물 검색

개발자 Q&A

Zookeeper::setWatcher 관련 질문

댓글목록

개발자 Q&A 포인트 정책

검색