Zookeeper

• Apache 재단 오픈소스 프로젝트
  
• 구성 정보 유지 관리,분산 동기화 제공하고 그룹 서비스를 제공하는 중앙 집중식 서비스
• Apache 내부 프로젝트 중 동물(hadoop, pig, hive) 을 zookeeper(사육사)가 관리 해준다는 의미?
• 디자인 목표
• 간단하게 설계
• 복제
• 서버들끼리 연결되어 서로 데이터가 복제
  
• 순서 존재
• 업데이트 순서 기록, 기록된 숫자 주키퍼 트랜잭션에 사용(이를 통해 동기화가 가능) 
  
• 빠른 속도

• Server
• 설정
• 최신 버전 다운로드
• 프로젝트 폴더 내 jar 파일 이용하여 Standalone 방식으로 동작 가능
• 설정 파일 생성
• conf/zoo.cfg

tickTime=2000
dataDir=/var/lib/zookeeper
clientPort=2181

• tickTime
• ZooKeeper에서 사용하는 기본 시간 단위 (milliseconds)
• 하트 비트를 수행하는 데 사용
  
• dataDir
• 메모리 내 데이터베이스 스냅 샷 저장할 위치
  
• clientPort
• client 연결을 대기하는 포트
• server start

java -cp zookeeper-3.4.13.jar:lib/log4j-1.2.17.jar:lib/slf4j-log4j12-1.7.25.jar:lib/slf4j-api-1.7.25.jar:conf org.apache.zookeeper.server.quorum.QuorumPeerMain conf/zoo.cfg

• 
  

• Client
• https://start.spring.io 에서 프로젝트 다운로드
• 
• 
  

• 다운 받은 프로젝트 내 application.properties 혹은 application.yml정보 설정

server.port: 8080
spring.application.name: libqa-client
spring:
  cloud:
    zookeeper:
      connect-string: localhost:2181

• build.grale 수정

dependencies {
	compile('org.springframework.cloud:spring-cloud-starter-zookeeper-all') {
		exclude group: 'org.apache.zookeeper', module: 'zookeeper'
	}
	compile('org.apache.zookeeper:zookeeper:3.4.12') {
		exclude group: 'org.slf4j', module: 'slf4j-log4j12'
	}
	implementation 'org.springframework.boot:spring-boot-starter-web'
	testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

• client start

• 
  

• 다중 client 확인을 위해서 client project 복사
• howling-client application.yml 수정

server.port: 8081
spring.application.name: howling-client
spring:
  cloud:
    zookeeper:
      connect-string: localhost:2181

• howling-client2

server.port: 8082
spring.application.name: howling-client
spring:
  cloud:
    zookeeper:
      connect-string: localhost:2181

• service discovery 테스트

@GetMapping("/callHowling/{applicationIndex}")
        public String callHowling(@PathVariable Integer applicationIndex) {
            List<ServiceInstance> clients = discoveryClient.getInstances("howling-client");
            String uri = clients.get(applicationIndex).getUri().toString();
            String requestUrl = uri + "/howling";
            this.discoveryClient.getServices().forEach(client ->
                    System.out.println(client));
            ResponseEntity<String> stockResponse =
                    restTemplate().exchange(requestUrl, HttpMethod.GET, null, new ParameterizedTypeReference<String>() {});

            return stockResponse.getBody();
        }

• eureka와 zookeeper 다른점
• eureka는 client의 spring.application.name이 host 정보라서 찾을수 있음
• zookeeper는 discoveryClient.getInstances("howling-client") 방식으로 spring.application.name으로 service를 찾아야함

• 상위 문제점 해결
• 설정의 문제
• 위치

@Autowired
private RestTemplate restTemplate;

@Bean
@LoadBalanced
public RestTemplate restTemplate() {
    return new RestTemplate();
}

• annotation

@Configuration
@EnableAutoConfiguration
@EnableDiscoveryClient
@EnableFeignClients
@SpringBootApplication
@EnableDiscoveryClient

참고 : https://zookeeper.apache.org/doc/current/zookeeperOver.html#sc_designGoals

https://zookeeper.apache.org/doc/current/zookeeperStarted.html

https://github.com/yongpwi/spring-cloud-zookeeper-client

https://github.com/yongpwi/spring-cloud-zookeeper-client2

https://github.com/yongpwi/spring-cloud-zookeeper-client3