# micro-rpc

**Repository Path**: startgis/micro-rpc

## Basic Information

- **Project Name**: micro-rpc
- **Description**: 本项目为仿照dubbo开发的rpc框架。
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: https://blog.csdn.net/Onthr
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2024-07-09
- **Last Updated**: 2024-07-09

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 如何开始

## 1.准备

1.引入本项目到项目中，直接把源码包作为一个maven模块导入，然后在需要的地方引入该依赖即可。

```xml
<dependency>
    <groupId>org.example</groupId>
    <artifactId>Micro-DUBBO</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>
```

2.启动你的**redis**，同时记住Host 和 port





## 2.编写xml配置文件

**dubbo-application.xml**

注意名称要一致，不然将识别不出来！！

以下*号为必填项!

```Xml
<?xml version="1.0" encoding="UTF-8" ?>
<dubbo>
    服务的基本信息
    <application>
        <name>*</name> 服务名
        <host>*</host> 服务主机
        <port>*</port> 服务端口
        <weight></weight> 权重，默认为1
    </application>
	
    注册中心配置连接
    <registry>
        <redis>
            <host>*</host> 注册中心ip
            <port>*</port> 注册中心端口
            <db></db>      注册中心数据库，默认为0
            <password></password>  注册中心密码
            <maxtotal></maxtotal>  你的最大连接数
        </redis>
    </registry>
 
    注册服务提供
    <serviceProvider>
        <interfaceName>publicInterface.HelloService</interfaceName> #服务接口全限定名
        <implClass>MicroRpc.provider.HelloServiceImpl</implClass> ##服务实现全限定类名
    </serviceProvider>

    <serviceProvider>
        <interfaceName>publicInterface.HiService</interfaceName>
        <implClass>MicroRpc.provider.HiServiceImpl</implClass>
    </serviceProvider>
    ...可有多个
	
    注册你需要的服务引用
    <serviceRefrence>
        <interfaceName>publicInterface.HiService</interfaceName> #服务接口全限定名
    </serviceRefrence>
    ...可有多个
    
</dubbo>
```



## 3.创建公共服务接口/ 服务提供者 / 服务消费者

**公共服务接口**

```java
public interface HelloService {

    public String say(String msg);

    public Object hi(Integer msg);

    public User getUserById(Integer id);

    public boolean updateUser(User user);

    public void testvoid();
}
```



**服务提供者示例**

```java
public class Provider1test {
    public static void main(String[] args) {
        AbstractApplicationContext context
                =new DefaultDubboApplicationContext(ProtocolTypes.DUBBO, LoadBalance.CONSISTENT_HASH); //第一个参数为协议，第二个参数为负载均衡策略
        try {
            context.refresh();
            System.out.println("刷新完毕 可以干点其他事");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}
```



**消费者示例代码**

```java
public class ConsumerTest1 {
    public static void main(String[] args) {
        AbstractApplicationContext context=
                new DefaultDubboApplicationContext(ProtocolTypes.DUBBO, LoadBalance.RANDAM_WEIGHT);
        try {
            context.refresh();
            System.out.println("刷新完毕");
            HelloService helloService = context.getProtocol().getService(HelloService.class);
            for (int i = 0; i < 20; i++) {
                System.out.println("===============================");
                System.out.println(helloService.say("markyao!!!"));
                System.out.println("===============================");
                Thread.sleep(1000);
            }
        } catch (ClassNotFoundException | InterruptedException e) {
            e.printStackTrace();
        }
    }

}
```





# 注册中心管理页面

本项目是基于SpringBoot开发的一个简单管理系统。

想要开启该服务，直接引入本项目，然后开启Springboot启动类即可 =>**com.markyao.ApplicationRunner**



然后访问页面: http://localhost:6380/index