com.baidu.brpc.server

Class BrpcPushProxy

java.lang.Object

com.baidu.brpc.server.BrpcPushProxy

All Implemented Interfaces:

net.sf.cglib.proxy.Callback, net.sf.cglib.proxy.MethodInterceptor

public class BrpcPushProxy
extends Object
implements net.sf.cglib.proxy.MethodInterceptor

Created by huwenwei on 2017/4/25.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BrpcPushProxy(CommunicationServer rpcServer, Class clazz) 初始化时提前解析好method信息，在rpc交互时会更快。

Method Summary

Modifier and Type	Method and Description
void	executeWithRetry(Request request, Response response)
static <T> T	getProxy(CommunicationServer rpcServer, Class clazz)
Map<String,RpcMethodInfo>	getRpcMethodMap()
Object	intercept(Object obj, Method method, Object[] args, net.sf.cglib.proxy.MethodProxy proxy) server push 调用用户接口时候， 实际执行的方法
protected void	pushCore(Request request, Response response)
protected io.netty.channel.Channel	selectChannel(Request request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BrpcPushProxy

protected BrpcPushProxy(CommunicationServer rpcServer,
                        Class clazz)

初始化时提前解析好method信息，在rpc交互时会更快。

Parameters:

rpcServer - rpcServer

clazz - rpc接口类

Method Detail

getProxy

public static <T> T getProxy(CommunicationServer rpcServer,
                             Class clazz)

intercept

public Object intercept(Object obj,
                        Method method,
                        Object[] args,
                        net.sf.cglib.proxy.MethodProxy proxy)
                 throws Throwable

server push 调用用户接口时候， 实际执行的方法

Specified by:

intercept in interface net.sf.cglib.proxy.MethodInterceptor

Parameters:

obj -

method -

args -

proxy -

Returns:

Throws:

Throwable

executeWithRetry

public void executeWithRetry(Request request,
                             Response response)

selectChannel

protected io.netty.channel.Channel selectChannel(Request request)

pushCore

protected void pushCore(Request request,
                        Response response)
                 throws RpcException

Throws:

RpcException

getRpcMethodMap

public Map<String,RpcMethodInfo> getRpcMethodMap()