百行代码完成Dubbo使用

Dear 丶 2023-01-10 05:23 189阅读 0赞

废话不多说直接上代码

### 项目目录 ###

├─.idea
    ├─apache-dubbo-consumer
    │  ├─src
    │  │  ├─main
    │  │  │  ├─java
    │  │  │  │  └─com
    │  │  │  │      └─mrduan
    │  │  │  └─resources
    ├─apache-dubbo-interface
    │  ├─src
    │  │  ├─main
    │  │  │  ├─java
    │  │  │  │  └─com
    │  │  │  │      └─mrduan
    │  │  │  │          └─service
    │  │  │  └─resources
    ├─apache-dubbo-provider
    │  ├─src
    │  │  ├─main
    │  │  │  ├─java
    │  │  │  │  └─com
    │  │  │  │      └─mrduan
    │  │  │  │          └─service
    │  │  │  │              └─impl
    │  │  │  │                  └─com
    │  │  │  │                      └─mrduan
    │  │  │  │                          └─service
    │  │  │  └─resources
    └─src
        ├─main
        │  ├─java
        │  └─resources
        └─test
            └─java

### maven坐标 ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>org.example</groupId>
        <artifactId>apache-dubbo</artifactId>
        <packaging>pom</packaging>
        <version>1.0-SNAPSHOT</version>
        <modules>
            <module>apache-dubbo-provider</module>
            <module>apache-dubbo-consumer</module>
            <module>apache-dubbo-interface</module>
        </modules>
        <dependencies>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>3.8.1</version>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.6</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.10</version>
            </dependency>
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.5</version>
            </dependency>
            <dependency>
                <groupId>io.netty</groupId>
                <artifactId>netty-all</artifactId>
                <version>4.1.32.Final</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.8.0</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>2.8.0</version>
            </dependency>
        </dependencies>
    </project>

### 服务端 ###

服务端只需要做4件事情  
1.编写业务代码实现业务接口在apache-dubbo-interface中定义接口  
然后在服务端和消费端都能引用的到

package com.mrduan.service;
    
    public interface IProviderService { 
    
        String sayHello(String name);
    
    }

2.在服务端编写接口实现 apache-dubbo-provider

package com.mrduan.service.impl;
    
    import com.mrduan.service.IProviderService;
    
    public class ProviderServiceImpl implements IProviderService { 
        public String sayHello(String name) { 
            return "hello," + name;
        }
    }

3.编写配置文件

<?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="provider" owner="mrduan">
            <dubbo:parameter key="qos.enable" value="true"/>
            <dubbo:parameter key="qos.accept.foreign.ip" value="false"/>
            <dubbo:parameter key="qos.port" value="55555"/>
        </dubbo:application>
    
        <dubbo:monitor protocol="registry"/>
    
        
        
    
        <dubbo:registry address="zookeeper://localhost:2181" check="false"/>
    
        
        <dubbo:protocol name="dubbo" port="20880"/>
    
        
        <dubbo:service interface="com.mrduan.service.IProviderService" ref="providerService"/>
    
        
        <bean id="providerService" class="com.mrduan.service.impl.ProviderServiceImpl"/>
    
    </beans>

4.启动zk

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70]  
5.编写启动类

package com.mrduan.service.impl.com.mrduan.service;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    public class ProviderStarter { 
    
        public static void main(String[] args) throws IOException { 
            ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
            applicationContext.start();
            System.in.read();
        }
    }

到次我们就可以启动项目了，执行main方法即可  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70 1]

### 消费端 ###

1.编写配置文件

<?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="consumer" owner="mrduan"/>
        
        
        
        <dubbo:registry address="zookeeper://localhost:2181" check="false"/>
    
        
        
        
        <dubbo:reference id="providerService" interface="com.mrduan.service.IProviderService"/>
    </beans>

2.编写启动类

package com.mrduan;
    
    import com.mrduan.service.IProviderService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    public class ComsumerStarter { 
        public static void main(String[] args) throws IOException { 
            ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
            applicationContext.start();
            IProviderService bean = applicationContext.getBean(IProviderService.class);
            String bruce = bean.sayHello("Bruce");
            System.out.println(bruce);
            System.in.read();
        }
    }

测试成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70 2]  
到此dubbo使用完成  
[参考文档][Link 1]  
[项目代码][Link 2]

如需自己编写微服务框架，可以参考  
[Netty手动实现Dubbo（含视频教程）][Netty_Dubbo]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70]: /images/20221119/5c5e696fade14d38bb2adc32640e6e91.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70 1]: /images/20221119/d7b3d79f280f41148a7d426ae2c673d0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210123101844881.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzE1OTAzOQ==,size_16,color_FFFFFF,t_70
[Link 1]: https://segmentfault.com/a/1190000019896723
[Link 2]: https://download.csdn.net/download/weixin_43159039/14925804
[Netty_Dubbo]: https://blog.csdn.net/weixin_43159039/article/details/112857080