今天就跟大家聊聊有關dubbo與zookeeper怎么在springboot中使用，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。
創(chuàng)建服務接口模塊
接口工程只提供接口，不提供實現(xiàn)，在后面的提供者和消費者中使用
在使用接口的模塊中只需要寫具體實現(xiàn)類，避免了在每個模塊中重復編寫接口
在接口中引入依賴包
org.projectlombok lombok true
創(chuàng)建一個實體類,一定要實現(xiàn)Serializable接口，否則dubbo協(xié)議之間無法傳輸
重慶分公司
重慶分公司
@Data
@AllArgsConstructor
public class User implements Serializable {
private String name;
}創(chuàng)建接口
public interface UserService {
List getAll();
List getAll2();
} 創(chuàng)建服務提供者
引入依賴
com.yls common-api 1.0-SNAPSHOT org.springframework.boot spring-boot-starter com.alibaba.boot dubbo-spring-boot-starter 0.2.0
修改配置文件
#服務名稱 dubbo.application.name=provider1 #注冊中心地址 dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183 #注冊中心類型 dubbo.registry.protocol=zookeeper #版本號 dubbo.application.version=3 # Dubbo Protocol #協(xié)議名稱 dubbo.protocol.name=dubbo #服務暴露端口 dubbo.protocol.port=20880
實現(xiàn)服務接口
//暴露服務
//這里的@Service是Dubbo提供的，不是spring中的
//version必填
@Service(version = "${dubbo.application.version}")
@Component
public class UserImpl implements UserService {
@Override
public List getAll() {
User user1 = new User("張三");
User user2 = new User("lisi");
List list = Arrays.asList(user1, user2);
return list;
}
} 啟動服務
//@EnableDubbo等價于在配置文件中配置dubbo.scan.base-packages
//掃描實現(xiàn)類所在的包，注冊Bean
@EnableDubbo
@SpringBootApplication
public class ProviderApplication {
public static void main(String[] args) {
SpringApplication.run(ProviderApplication.class,args);
}
}創(chuàng)建消費者
引入依賴
org.springframework.boot spring-boot-starter-web com.alibaba.boot dubbo-spring-boot-starter 0.2.0 com.yls common-api 1.0-SNAPSHOT
修改配置文件
#注冊中心 dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183 dubbo.registry.protocol=zookeeper #dubbo應用名稱 dubbo.application.name=consumer1
實現(xiàn)消費接口
//服務消費者的Service是spring的
@Service
public class OrderImpl implements OrderService {
//使用dubbo提供的@Reference訪問遠程服務
//version對應服務提供者的version
@Reference(version = "3")
private UserService userService;
@Override
public List init() {
List list = userService.getAll();
list.forEach(item -> System.out.println(item.getName()));
return list;
}
} 創(chuàng)建controller
@Controller
public class OrderController {
@Autowired
private OrderService orderService;
@ResponseBody
@RequestMapping("/init")
public List init() {
return orderService.init();
}
} 啟動服務消費者
@EnableDubbo
@SpringBootApplication
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}dubbo相關補充
dubbo使用本地緩存方式，如果注冊中心全部宕機，dubbo也能正常工作，就算沒有注冊中心，dubbo也能通過dubbo直連通信
//使用dubbo提供的@Reference訪問遠程服務 //version對應服務提供者的version //url:如果沒有注冊中心，可以通過url配置服務提供者的dubbo協(xié)議端口，進行dubbo直連 @Reference(version = "3",url ="127.0.0.1:20880" ) private UserService userService;
看完上述內(nèi)容，你們對dubbo與zookeeper怎么在springboot中使用有進一步的了解嗎？如果還想了解更多知識或者相關內(nèi)容，請關注創(chuàng)新互聯(lián)網(wǎng)站建設公司行業(yè)資訊頻道，感謝大家的支持。
另外有需要云服務器可以了解下創(chuàng)新互聯(lián)建站www.cdcxhl.com，海內(nèi)外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。
