Skip to content

xincao9/yurpc

Repository files navigation

yurpc

高性能RPC框架

yurpc 基于java的高性能开源RPC框架,使用方式上类似dubbo,提倡面向接口编程,如果您熟悉dubbo很容易迁移到yurpc;并享受高性能带来的服务体验。提供springboot高度集成starter包,实现零配置使用

logo

yurpc 实战

maven 依赖

<dependency>
    <groupId>com.github.xincao9</groupId>
    <artifactId>yurpc-spring-boot-starter</artifactId>
    <version>1.2.6</version>
</dependency>

实体定义


public class Say {

    private Integer id;
    private String body;

    public Say(Integer id, String body) {
        this.id = id;
        this.body = body;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getBody() {
        return body;
    }

    public void setBody(String body) {
    
        this.body = body;
    }

    @Override
    public String toString() {
        return JSONObject.toJSONString(this, SerializerFeature.DisableCircularReferenceDetect);
    }
}

服务接口定义

public interface SayService {

    Say perform(Say say);
}

提供者实现服务接口

@YUProvider
public class SayServiceImpl implements SayService {

    @Override
    public Say perform(Say say) {
        return say;
    }

}

服务提供者启动类

@SpringBootApplication
@EnableYuRPC(server = true)
public class ApplicationProvider {

    public static void main(String... args) {
        SpringApplication.run(ApplicationProvider.class, args);
    }
}

服务消费者启动类

@SpringBootApplication
@EnableYuRPC(client = true)
public class ApplicationConsumer {

    @YUConsumer
    private SayService sayService; // 可以在任何spring bean 中注入yurpc服务


    public static void main(String... args) {
        SpringApplication.run(ApplicationConsumer.class, args);
    }

    @Bean
    public CommandLineRunner commandLineRunner() {
        return (String... args) -> {
            for (int no = 0; no < 100; no++) {
                String value = RandomStringUtils.randomAscii(128);
                Say say = new Say(no, value);
                System.out.println(sayService.perform(say)); // 远程调用yurpc服务
            }
        };
    }

}

application.properties

## 服务发现注册或订阅的zk地址,暂时只支持zookeeper的注册中心
yurpc.discovery.zookeeper=localhost:2181

## 消费者配置
yurpc.client.connectionTimeoutMS=5000 // 服务连接超时时间
yurpc.client.invokeTimeoutMS=1000 // 服务调用超时时间

## 提供者配置
yurpc.server.port=12306 // 服务监听端口

温馨提示

  • 欢迎查看示例 examples
  • yurpc 本身并不是必须和springboot一起使用,在示例中可以查看
  • 单独使用的话,配置文件名为 config.properties,在示例中可以查看
  • @EnableYuRPC(server = true, client = true) 意味着服务角色同为消费端和提供者使用

联系方式