Dubbo+zookeeper搭配分布式服務(wù)的過程詳解
分布式架構(gòu):
1.當垂直應(yīng)用越來越多,應(yīng)用之間交互不可避免,將核心業(yè)務(wù)抽取出來,作為獨立的服務(wù),逐漸形成穩(wěn)定的服務(wù)中心,前端應(yīng)用能更快速的響應(yīng)多變的市場需求。
2.此時,用于提高業(yè)務(wù)復用及整合的 分布式服務(wù)框架(RPC) 是關(guān)鍵。
Dubbo 是什么
- 一款分布式服務(wù)框架
- 高性能和透明化的RPC遠程服務(wù)調(diào)用方案
- SOA服務(wù)治理方案
Dubbo:
作為分布式架構(gòu)比較后的框架,同時也是比較容易入手的框架,適合作為分布式的入手框架,下面是簡單的搭建過程
工具:idea+tomact+zookeeper (知識點:jsp,spring,springmvc,maven)
思想:

依賴:
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>5.2.5.RELEASE</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.2</version>
</dependency>
<!--zookeeper依賴-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.1.0</version>
</dependency>
<dependency>
<groupId>com.atchengdu</groupId>
<artifactId>001-interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>工程分布:

provider實現(xiàn)interface提供服務(wù),constomer消費provider提供的服務(wù)
interface:

package com.atchengdu.serviceinterface;
import com.atchengdu.pojo.User;
public interface Userservice {
//獲取user的信息
User getuserByid(Integer ie);
}
package com.atchengdu.pojo;
import java.io.Serializable;
public class User implements Serializable {
private Integer id ;
private String name;
public User(Integer id, String name) {
this.id = id;
this.name = name;
}
public User() {
public Integer getId() {
return id;
public void setId(Integer id) {
public String getName() {
return name;
public void setName(String name) {
@Override
public String toString() {
return "User{" +
"id=" + id +
", name='" + name + '\'' +
'}';provider:

package com.atchengdu.Modulserviceimpl;
import com.atchengdu.pojo.User;
import com.atchengdu.serviceinterface.Userservice;
public class Userserviceimpl implements Userservice {
@Override
public User getuserByid(Integer ie) {
User user=new User(1,"張三");
return user;
}
}<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!--聲明名稱-->
<dubbo:application name="002-provider"></dubbo:application>
<!--設(shè)置協(xié)議和端口號-->
<dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
<!--使用注冊中心-->
<dubbo:registry address="zookeeper://localhost:2181"></dubbo:registry>
<!--暴露服務(wù)接口-->
<dubbo:service interface="com.atchengdu.serviceinterface.Userservice" ref="userserviceimpl"></dubbo:service>
<!--加載業(yè)務(wù)實實現(xiàn)了-->
<bean id="userserviceimpl" class="com.atchengdu.Modulserviceimpl.Userserviceimpl"></bean>
</beans>constomer:

package com.atchengdu.webcontroller;
import com.atchengdu.pojo.User;
import com.atchengdu.serviceinterface.Userservice;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
@Controller
public class Usercontroller {
@Autowired
private Userservice userservice;
@RequestMapping("/user")
public String user(Model model,Integer id ){
User user = userservice.getuserByid(id);
model.addAttribute("user",user);
return "user";
}
}<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:tx="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/task https://www.springframework.org/schema/task/spring-task.xsd
http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd">
<context:component-scan base-package="com.atchengdu.webcontroller">
</context:component-scan>
<mvc:annotation-driven></mvc:annotation-driven>
<bean id="internalResourceViewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="suffix" value=".jsp"></property>
<property name="prefix" value="/"></property>
</bean>
</beans><?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="003-constomer"></dubbo:application>
<dubbo:registry address="zookeeper://localhost:2181"></dubbo:registry>
<dubbo:reference id="userservice" interface="com.atchengdu.serviceinterface.Userservice"></dubbo:reference>
</beans>到此這篇關(guān)于Dubbo+zookeeper搭配分布式服務(wù)的過程詳解的文章就介紹到這了,更多相關(guān)Dubbo+zookeeper分布式服務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
eclipse輸出Hello World的實現(xiàn)方法
這篇文章主要介紹了eclipse輸出Hello World的實現(xiàn)方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-11-11
SpringCloud GateWay動態(tài)路由用法
網(wǎng)關(guān)作為所有項目的入口,不希望重啟,因此動態(tài)路由是必須的,動態(tài)路由主要通過RouteDefinitionRepository接口實現(xiàn),其默認的實現(xiàn)是InMemoryRouteDefinitionRepository,即在內(nèi)存中存儲路由配置,可基于這個map對象操作,動態(tài)路由的實現(xiàn)方案有兩種2024-10-10
實例解決Java異常之OutOfMemoryError的問題
在本篇文章中,我們給大家分享了關(guān)于解決Java異常之OutOfMemoryError的問題的方法,有此需要的朋友們學習下。2019-02-02

