「java中的rpc」Java中的参数传递都是值传递

博主:adminadmin 2022-12-21 00:51:07 71

今天给各位分享java中的rpc的知识,其中也会对Java中的参数传递都是值传递进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!

本文目录一览:

主流的RPC框架有哪些?

RPC是远程过程调用的简称,广泛应用在大规模分布式应用中,作用是有助于系统的垂直拆分,使系统更易拓展。Java中的RPC框架比较多,各有特色,广泛使用的有RMI、Hessian、Dubbo等。RPC还有一个特点就是能够跨语言。

1、RMI(远程方法调用)

JAVA自带的远程方法调用工具,不过有一定的局限性,毕竟是JAVA语言最开始时的设计,后来很多框架的原理都基于RMI,RMI的使用如下:

对外接口

span style="font-size:12px;"public interface IService extends Remote {  

  

    public String queryName(String no) throws RemoteException;  

  

}/span

服务实现

import java.rmi.RemoteException;  

import java.rmi.server.UnicastRemoteObject;  

  

// 服务实现  

public class ServiceImpl extends UnicastRemoteObject implements IService {  

  

    /** 

     */  

    private static final long serialVersionUID = 682805210518738166L;  

  

    /** 

     * @throws RemoteException 

     */  

    protected ServiceImpl() throws RemoteException {  

        super();  

    }  

  

    /* (non-Javadoc) 

     * @see com.suning.ebuy.wd.web.IService#queryName(java.lang.String) 

     */  

    @Override  

    public String queryName(String no) throws RemoteException {  

        // 方法的具体实现  

        System.out.println("hello" + no);  

        return String.valueOf(System.currentTimeMillis());  

    }  

      

}  

RMI客户端

[java] view plain copy

import java.rmi.AccessException;  

import java.rmi.NotBoundException;  

import java.rmi.RemoteException;  

import java.rmi.registry.LocateRegistry;  

import java.rmi.registry.Registry;  

  

// RMI客户端  

public class Client {  

  

    public static void main(String[] args) {  

        // 注册管理器  

        Registry registry = null;  

        try {  

            // 获取服务注册管理器  

            registry = LocateRegistry.getRegistry("127.0.0.1",8088);  

            // 列出所有注册的服务  

            String[] list = registry.list();  

            for(String s : list){  

                System.out.println(s);  

            }  

        } catch (RemoteException e) {  

              

        }  

        try {  

            // 根据命名获取服务  

            IService server = (IService) registry.lookup("vince");  

            // 调用远程方法  

            String result = server.queryName("ha ha ha ha");  

            // 输出调用结果  

            System.out.println("result from remote : " + result);  

        } catch (AccessException e) {  

              

        } catch (RemoteException e) {  

              

        } catch (NotBoundException e) {  

              

        }  

    }  

}  

RMI服务端

[java] view plain copy

import java.rmi.RemoteException;  

import java.rmi.registry.LocateRegistry;  

import java.rmi.registry.Registry;  

  

// RMI服务端  

public class Server {  

  

    public static void main(String[] args) {  

        // 注册管理器  

        Registry registry = null;  

        try {  

            // 创建一个服务注册管理器  

            registry = LocateRegistry.createRegistry(8088);  

  

        } catch (RemoteException e) {  

              

        }  

        try {  

            // 创建一个服务  

            ServiceImpl server = new ServiceImpl();  

            // 将服务绑定命名  

            registry.rebind("vince", server);  

              

            System.out.println("bind server");  

        } catch (RemoteException e) {  

              

        }  

    }  

}

2、Hessian(基于HTTP的远程方法调用)

基于HTTP协议传输,在性能方面还不够完美,负载均衡和失效转移依赖于应用的负载均衡器,Hessian的使用则与RMI类似,区别在于淡化了Registry的角色,通过显示的地址调用,利用HessianProxyFactory根据配置的地址create一个代理对象,另外还要引入Hessian的Jar包。

3、Dubbo(淘宝开源的基于TCP的RPC框架)

基于Netty的高性能RPC框架,是阿里巴巴开源的,总体原理如下:

分析JAVA中几种常用的RPC框架

HTTP/1.1 协议规定的 HTTP 请求方法有 OPTIONS、GET、HEAD、POST、PUT、DELETE、TRACE、CONNECT 这几种。其中,POST 一般用来向服务端提交数据,本文主要讨论 POST 提交数据的几种方式。

我们知道,HTTP 协议是以 ASCII 码传输,建立在 TCP/IP 协议之上的应用层规范。规范把 HTTP 请求分为三个部分:状态行、请求头、消息主体。类似于下面形式:

method request-URL version headers entity-body

协议规定,POST 提交的数据必须放在消息主体(entity-body)中,但协议并没有规定数据必须使用什么编码方式。实际上,开发者完全可以自己决定消息主体的格式,只要最后发送的 HTTP 请求满足上面的格式就可以。

rpc的实现机制是什么

RPC 的全称是 Remote Procedure Call 是一种进程间通信方式。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数,而不用程序员显式编码这个远程调用的细节。即无论是调用本地接口/服务的还是远程的接口/服务,本质上编写的调用代码基本相同。

比如两台服务器A,B,一个应用部署在A服务器上,想要调用B服务器上应用提供的函数或者方法,由于不在一个内存空间,不能直接调用,这时候需要通过就可以应用RPC框架的实现来解决。

RPC 会隐藏底层的通讯细节(不需要直接处理Socket通讯或Http通讯)

RPC 是一个请求响应模型。客户端发起请求,服务器返回响应(类似于Http的工作方式)

RPC 在使用形式上像调用本地函数(或方法)一样去调用远程的函数(或方法)。

二、常见RPC框架

几种比较典型的RPC的实现和调用框架。

(1)RMI实现,利用java.rmi包实现,基于Java远程方法协议(Java Remote Method Protocol)

和java的原生序列化。

(2)Hessian,是一个轻量级的remoting onhttp工具,使用简单的方法提供了RMI的功能。 基于HTTP协议,采用二进制编解码。

(3)THRIFT是一种可伸缩的跨语言服务的软件框架。thrift允许你定义一个描述文件,描述数据类型和服务接口。依据该文件,编译器方便地生成RPC客户端和服务器通信代码。

二、RPC框架实现原理

在RPC框架中主要有三个角色:Provider、Consumer和Registry。如下图所示:

RPC框架面试总结-RPC原理及实现

节点角色说明:

* Server: 暴露服务的服务提供方。

* Client: 调用远程服务的服务消费方。

* Registry: 服务注册与发现的注册中心。

三、RPC调用流程

RPC基本流程图:

RPC框架面试总结-RPC原理及实现

一次完整的RPC调用流程(同步调用,异步另说)如下:

1)服务消费方(client)调用以本地调用方式调用服务;

2)client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体;

3)client stub找到服务地址,并将消息发送到服务端;

4)server stub收到消息后进行解码;

5)server stub根据解码结果调用本地的服务;

6)本地服务执行并将结果返回给server stub;

7)server stub将返回结果打包成消息并发送至消费方;

8)client stub接收到消息,并进行解码;

9)服务消费方得到最终结果。

RPC框架的目标就是要2~8这些步骤都封装起来,让用户对这些细节透明。

四、服务注册发现

RPC框架面试总结-RPC原理及实现

服务提供者启动后主动向注册中心注册机器ip、port以及提供的服务列表;

服务消费者启动时向注册中心获取服务提供方地址列表,可实现软负载均衡和Failover;

五、使用到的技术

1、动态代理

生成 client stub和server stub需要用到 Java 动态代理技术 ,我们可以使用JDK原生的动态代理机制,可以使用一些开源字节码工具框架 如:CgLib、Javassist等。

2、序列化

为了能在网络上传输和接收 Java对象,我们需要对它进行 序列化和反序列化操作。

* 序列化:将Java对象转换成byte[]的过程,也就是编码的过程;

* 反序列化:将byte[]转换成Java对象的过程;

可以使用Java原生的序列化机制,但是效率非常低,推荐使用一些开源的、成熟的序列化技术,例如:protobuf、Thrift、hessian、Kryo、Msgpack

关于序列化工具性能比较可以参考:jvm-serializers

3、NIO

当前很多RPC框架都直接基于netty这一IO通信框架,比如阿里巴巴的HSF、dubbo,Hadoop Avro,推荐使用Netty 作为底层通信框架。

4、服务注册中心

可选技术:

* Redis

* Zookeeper

* Consul

* Etcd

RPC和注册中心的简介

网络调用RPC 假设一个web 调用另外一个service 就符合RPC协议

在网络传输中的数据是序列化及返回为反序列化传输

什么是RPC:RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务

RPC的原理:RPC协议的底层原理,就是对象的序列化、反序列化以及序列化后数据的传输。

RPC协议的核心组成部分:网络传输协议:http,tcp(推荐使用tcp); dubbo序列化和反序列化:可以使用Java原生的序列化和反序列化,也可以使用高性能序列化/反序列化工具,如Hessian,FST等,还可以使用表单序列化。

常见的RPC框架:Dubbo,SpringCloud, Thrift,Motan,gRPC

注册中心的作用:1:服务端服务的注册和客户端服务的发现 2、提高系统的高可用性 3、提高系统的可伸缩性 4、集中管理服务 ;常见的注册中心:zookeeper,Redis;

服务的发现:引入注册中心

java rpc框架哪个好 知乎

Thrift 是由 Facebook 开源的一个 RPC 框架,现在已经挂在 apache.org 下了。主要的几个好处:

1. 支持非常多语言,包括在 WEB 开发中很常用的 PHP,以及最重要的 C++/Python/Java 等 WEB后端常用语言,当然,还包括很 cool 的 Ruby、Erlang。

2. 完整的 RPC 框架实现,用脚本生成通讯相关的框架代码,开发者只需要集中精力处理好 业务逻辑。比如搭建一个 Hello World Service 只需要几分钟。

3.拥有被 Facebook、Last.fm 等不少大规模互联网应用验证过的性能和可用性。

Hessian是一款基于HTTP协议的RPC框架,采用的是二进制RPC协议,非常轻量级 ,且速度较快。

当然,还有Hetty,它是一款构建于Netty和Hessian基础上的高性能的RPC框架。

java protobuf 定义rpc服务怎么调用

1.,选择其中的win版本下载,我选择的是protoc-2.4.1-win32.zip

2.下载一个protobuf-java-2.4.1.jar文件(注意,要与你刚才下的proto.exe版本相同)

然后就开始开发了。

步骤:

1.用记事本编写一个.proto文件:

}如:编写的是test.proto

package protobuf;

option java_package = "com.sq.protobuf";

option java_outer_classname = "FirstProtobuf";

message testBuf {

required int32 ID = 1;

required string Url = 2;

}

将其放在与刚解压的protoc.exe同级目录中。

2.在cmd中,到protoc-2.4.1-win32文件夹下,

执行

E:\protoc-2.4.1-win32 protoc.exe --java_out=./ test.proto

则可以找到的一个生成的FirstProtobuf.java文件。

3.在MyEclipse中新建一个java project,建立包com.sq.protobuf,然后将刚才生成的FirstProtobuf.java文件放在其下面。

此时会报错,因为没有引入jar包,在package视图下,将protobuf-java-2.4.1.jar引入,即可解决问题。

java中的rpc的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于Java中的参数传递都是值传递、java中的rpc的信息别忘了在本站进行查找喔。

The End

发布于:2022-12-21,除非注明,否则均为首码项目网原创文章,转载请注明出处。