client

目前josoa-rpc支持有2种通讯协议:

rmi协议
jkr实现的协议, 默认使用这种协议

因此导致client也有两种实现

RmiRpcClient, 实现rmi协议
JkrRpcClient, 实现jkr协议

其类族如下

IRpcClient
	JkrRpcClient
	RmiRpcClient

使用client

我们一般是使用服务引用者 Referer 来引用与调用远端服务, 其底层实现是调用 IRpcClient.connect(url) 来获得IConnection连接对象, 并将方法调用封装为rpc请求, 通过连接对象来发送出去

client配置 rpc-client.yaml

关键配置项

serializer -- 序列器类型
loadbalancer -- 序列器类型
shardingStrategy -- 批量请求的分片策略
servicePackages -- 要提供的服务类所在的包路径

# 客户端配置
duplex: true # 是否双工, 就是双向rpc, 就是server也可以调用client, 但是client不在注册中心注册
serializer: fst # 序列器类型
loadbalancer: random # 均衡负载类型
shardingStrategy: average # 批量请求的分片策略
servicePackages: # service类所在的包路径
    - net.jkcode.jksoa.rpc.example # 示例服务
    - net.jkcode.jksoa.tracer.common.service.remote # tracer组件的collector服务
registryOrSwarm: true # 是否使用注册中心, 否则使用docker swarm集群来做服务发现
swarmMqType: kafka # docker swarm模式下服务发现通知的消息队列类型: 暂时只支持 kafka
swarmMqName: swarmDiscovery # 消息连接配置名, 对应如 kafka-consumer.yaml / kafka-producer.yaml 中的配置名
package2swarmServer: # 包名转为swarm服务名(server)
    # key是包名的模式: 用.分割多层包名, *代表一层任意包名, **代表多层任意包名
    # value是server地址: 可以带变量, 变量格式为`$层序号`, 如$0代表第1层包名, $1代表第2层包名, 以此类推
    'net.jkcode.jksoa.rpc.example': 'jkr://jksoa_rpcserver:9080'
    #'net.jkcode.jksoa.rpc.example': jksoa_rpcserver # 简写，省略协议jkrp跟端口9080
    '**': 'jkr://$2_$3:9080'
    #'**': $2_$3 # 简写，省略协议jkrp跟端口9080
connectTimeoutMillis: 500 # 连接超时，int类型，单位：毫秒
requestTimeoutMillis: !!java.lang.Long 5000 # 请求超时，Long类型，单位：毫秒
maxTryCount: 2 # 最大尝试次数, 用于支持失败重试, 用在 RetryRpcResponseFuture
connectType: fixed # 连接类型: 1 single 复用单一连接 2 pooled 连接池 3 fixed 固定几个连接
lazyConnect: false # 是否延迟创建连接
minConnections: 2 # 最小连接数, 用在 PooledConnections/FixedConnections
maxConnections: 10 # 最大连接数, 用在 PooledConnections

IRpcClient 接口

IRpcClient 接口就一个方法 connect(url), 返回的是 IConnection 实例.

package net.jkcode.jksoa.rpc.client

import net.jkcode.jksoa.common.Url
import java.io.Closeable

/**
 * rpc协议-客户端
 *
 * @Description:
 * @author shijianhang<772910474@qq.com>
 * @date 2017-09-08 2:58 PM
 */
interface IRpcClient: Closeable {

    /**
     * 连接server
     *
     * @param url
     * @return
     */
    fun connect(url: Url): IConnection
}

IRpcClient 的实现

RmiRpcClient

实现很简单, connect(url) 返回的是 RmiConnection 对象

JkrRpcClient

实现就比较复杂, connect(url) 返回的是 NettyConnection 对象

FilesExpand file tree

client.md

Latest commit

History