那些年我造的轮子之RPC
storm-rpc
快速开始(使用Spring Boot)
Api
接口IHelloService.javaphp
package me.stormma.api;
/** * @author stormma stormmaybin@gmail.com */
public interface IHelloService {
String sayHello(String name);
}
复制代码
服务接口pom依赖java
<?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>
<artifactId>storm-rpc-spring-boot-starter-test-api</artifactId>
</project>
复制代码
Provider
服务提供者实现HelloService.javagit
package me.stormma.storm.rpc.spring.boot.starter.test.provider.provider;
import me.stormma.annoation.Provider;
import me.stormma.api.IHelloService;
/** * @author stormma stormmaybin@gmail.com */
@Provider(interfaceClass = IHelloService.class, version = "2.0.0")
public class HelloService implements IHelloService {
@Override
public String sayHello(String name) {
return "hello " + name + "!";
}
}
复制代码
服务提供者pom依赖github
<?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>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter-test-provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>storm-rpc-spring-boot-starter-test-provider</name>
<description>storm-rpc-spring-boot-starter-test-provider</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter-test-api</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
复制代码
服务提供者启动类StormRpcSpringBootStarterTestProviderApplication.javaweb
package me.stormma.storm.rpc.spring.boot.starter.test.provider;
import me.stormma.rpc.spring.boot.annotation.EnableStormRpcConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableStormRpcConfiguration
public class StormRpcSpringBootStarterTestProviderApplication {
public static void main(String[] args) {
SpringApplication.run(StormRpcSpringBootStarterTestProviderApplication.class, args);
}
}
复制代码
服务提供者配置文件application.properties算法
spring.storm.rpc.server=true
spring.storm.rpc.host=127.0.0.1
spring.storm.rpc.port=52057
spring.storm.rpc.weight=3
spring.storm.rpc.registry=139.199.27.243:2181
spring.storm.rpc.basePackage=me.stormma.storm.rpc.spring.boot.starter.test.provider
spring.storm.rpc.name=provider
复制代码
Consumer
服务消费者测试类HelloServiceTest.javaspring
package me.stormma.storm.rpc.spring.boot.starter.test.consumer.consumer;
import me.stormma.api.IHelloService;
import me.stormma.rpc.spring.boot.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
/** * @author stormma stormmaybin@gmail.com */
@RestController
public class HelloServiceTest {
@Reference(interfaceClass = IHelloService.class, version = "2.0.0")
private IHelloService helloService;
public int a = 0;
@GetMapping("/say/hello/{name}")
public String test(@PathVariable String name) {
return helloService.sayHello(name);
}
}
复制代码
服务消费者pom依赖apache
<?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>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter-test-consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>storm-rpc-spring-boot-starter-test-consumer</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter-test-api</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>me.stormma</groupId>
<artifactId>storm-rpc-spring-boot-starter</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
复制代码
服务消费者启动类StormRpcSpringBootStarterTestConsumerApplication.javabootstrap
package me.stormma.storm.rpc.spring.boot.starter.test.consumer;
import me.stormma.rpc.spring.boot.annotation.EnableStormRpcConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableStormRpcConfiguration
public class StormRpcSpringBootStarterTestConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(StormRpcSpringBootStarterTestConsumerApplication.class, args);
}
}
复制代码
服务消费者配置文件application.propertiesapi
spring.storm.rpc.discover=139.199.27.243:2181
spring.storm.rpc.name=consumer
server.port=8090
复制代码
快速开始(原生)
Api
服务接口IHelloService.java
package me.stormma.api;
/** * @author stormma stormmaybin@gmail.com */
public interface IHelloService {
String sayHello(String name);
}
复制代码
Provider
服务提供者实现HelloService.java
package me.stormma.provider;
import me.stormma.annoation.Provider;
import me.stormma.api.IHelloService;
/** * @author stormma stormmaybin@gmail.com */
@Provider(interfaceClass = IHelloService.class, version = "1.0.0")
public class HelloService implements IHelloService {
@Override
public String sayHello(String name) {
return "hello " + name;
}
}
复制代码
服务提供者启动类ServerBootstrap.java
package me.stormma.provider;
import me.stormma.constants.Constants;
import me.stormma.rpc.model.ServerInfo;
import me.stormma.rpc.netty.bootstrap.RpcServer;
import me.stormma.rpc.registry.ServiceRegistry;
import me.stormma.rpc.registry.zk.ZookeeperServiceRegistry;
/** * @author stormma stormmaybin@gmail.com */
public class ServerBootstrap {
public static void main(String... args) throws Exception {
String zkServer = "139.199.27.243:2181";
ServiceRegistry serviceRegistry = new ZookeeperServiceRegistry(zkServer);
ServerInfo serverInfo = new ServerInfo(Constants.DEFAULT_HOST, Constants.DEFAULT_PORT
, Constants.SERVER_DEFAULT_WEIGHT);
RpcServer rpcServer = new RpcServer(serviceRegistry, serverInfo);
rpcServer.start("me.stormma.provider");
}
}
复制代码
Consumer
服务消费者实现类ConsumerClient.java
package me.stormma.consumer;
import me.stormma.api.IHelloService;
import me.stormma.rpc.proxy.DefaultProxy;
import me.stormma.rpc.registry.ServiceDiscover;
import me.stormma.rpc.registry.zk.ZookeeperServiceDiscover;
/** * @author stormma stormmaybin@gmail.com */
public class ConsumerClient {
public static void main(String[] args) {
String zkServer = "139.199.27.243:2181";
ServiceDiscover serviceDiscover = new ZookeeperServiceDiscover(zkServer);
DefaultProxy proxy = new DefaultProxy(serviceDiscover);
IHelloService helloService = proxy.createProxy(IHelloService.class, "1.0.0");
System.out.println(helloService.sayHello("stormma"));
System.exit(0);
}
}
复制代码
storm-rpc技术依赖
-
zookeeper, 使用zookeeper进行服务注册与发现(服务名称做为服务提供者启动以后建立zk持久性节点保存, 服务对应的地址建立为临时性节点的内容, 实现动态 发现服务宕机和上线, 临时性节点表示为'host:port$weight', host:port表明服务地址, weight表示为该服务地址的权重, 用来实现负载均衡, 负载均衡算法参考 dubbo的负载均衡算法, 基于权重的负载均衡算法)
-
netty, 使用netty进行服务之间的网络通讯, netty的使用参考<>这本书。
-
kryo, 使用kryo进行序列化和反序列化。
-
动态代理(本项目提供了原生JDK动态代理和CGLIB来实现的动态代理, 用户能够自行配置使用哪一种代理方式), 具体工做流程如: 重写BeanPostProcess来实现 解析Bean的字段是否包含
Reference注解, 若是包含就建立个代理对象注入。
storm-rpc功能点
- 服务注册和发现
- 负载均衡
- 集成spring boot
- 远程调用
- 断线重连(后续增长)
后记
storm-rpc从开始开发到一个版本的推出前先后后经历了一周多, 实现借鉴了dubbo的不少代码, 期待你的加入能让storm-rpc走向完善。
相关文章
- 1. 造轮子，为何鄙视造轮子，我同意造轮子！
- 2. Android的那些轮子
- 3. 造个轮子之基于 Netty 实现本身的 RPC 框架
- 4. 那些年的我们
- 5. 我在 MySQL 的那些年
- 6. 我要造轮子系列-一个轮子的诞生过程
- 7. 那些最好的轮子 - PHP篇
- 8. 那些惊艳的 GIS 轮子
- 9. 我厌倦了 Redux，那就造个轮子 Rectx：第三集
- 10. 造轮子系列之Protobuf
- 更多相关文章...
- • NoSQL数据库的优势有哪些？ - NoSQL教程
- • 伪造ICMP数据包的Ethernet层 - TCP/IP教程
- • 互联网组织的未来：剖析GitHub员工的任性之源
- • 为了进字节跳动，我精选了29道Java经典算法题，带详细讲解
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. python的安装和Hello，World编写
- 2. 重磅解读：K8s Cluster Autoscaler模块及对应华为云插件Deep Dive
- 3. 鸿蒙学习笔记2（永不断更）
- 4. static关键字 和构造代码块
- 5. JVM笔记
- 6. 无法启动 C/C++ 语言服务器。IntelliSense 功能将被禁用。错误: Missing binary at c:\Users\MSI-NB\.vscode\extensions\ms-vsc
- 7. 【Hive】Hive返回码状态含义
- 8. Java树形结构递归（以时间换空间）和非递归（以空间换时间）
- 9. 数据预处理---缺失值
- 10. 都要2021年了，现代C++有什么值得我们学习的？
欢迎关注本站公众号,获取更多信息
相关文章
- 1. 造轮子，为何鄙视造轮子，我同意造轮子！
- 2. Android的那些轮子
- 3. 造个轮子之基于 Netty 实现本身的 RPC 框架
- 4. 那些年的我们
- 5. 我在 MySQL 的那些年
- 6. 我要造轮子系列-一个轮子的诞生过程
- 7. 那些最好的轮子 - PHP篇
- 8. 那些惊艳的 GIS 轮子
- 9. 我厌倦了 Redux，那就造个轮子 Rectx：第三集
- 10. 造轮子系列之Protobuf