dubbo实战之三：使用Zookeeper注册中心，2024年最新java 高并发面试题

spring-boot-dependencies

2.3.3.RELEASE

pom

import

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-test

test

com.bolingcavalry

practiceinterface

${project.version}

org.apache.dubbo

dubbo-dependencies-zookeeper

pom

org.projectlombok

lombok

org.apache.dubbo

dubbo-spring-boot-starter

org.springframework.boot

spring-boot-maven-plugin

${springboot.version}

2. 配置文件application.yml，要注意的是registry.address的值zookeeper://192.168.50.43:2181，这就是Zookeeper注册中心的配置：

dubbo:

application:

#application-name 本模块名字

name: springboot-zk-provider

registry:

address: zookeeper://192.168.50.43:2181

protocol:

name: dubbo

port: 20880

3. 编写服务实现类DemoServiceImpl.java，注意@Service注解将当前类的实例作为远程服务对外暴露：

package com.bolingcavalry.springbootzkprovider;

import com.bolingcavalry.dubbopractice.service.DemoService;

import lombok.extern.slf4j.Slf4j;

import org.apache.dubbo.config.annotation.Service;

import org.apache.dubbo.rpc.RpcContext;

@Slf4j

@Service

public class DemoServiceImpl implements DemoService {

@Override

public String sayHello(String name) {

log.info("I’m springboot-zk-provider, Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

return "I’m springboot-zk-provider, Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();

}

}

4. 编写SpringBoot启动类SpringBootZKProviderApplication.java，注意要添加@EnableDubbo注解：

package com.bolingcavalry.springbootzkprovider;

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication

@EnableDubbo

public class SpringBootZKProviderApplication {

public s