go语言微服务之RPC协议[通俗易懂]

go语言微服务之RPC协议[通俗易懂]1什么是RPCRemoteProcedureCallProtocol–远程过程调用协议!IPC:进程间通信RPC:远程进程通信–应用层协议(http协议同层),底层用TCP实现。理解RPC:像调用本地函数一样,去调用远程函数。通过rpc协议,传递:函数名,函数参数。达到在本地,调用远端函数,得返回值到本地的目标。 为什么微服务要使用RPC:每个服务都被封转成进程,彼此“独立”。 进程与进程之间,可以使用不同的语言实现。2RPC使用的步骤服务端:注册rpc

大家好,又见面了,我是你们的朋友全栈君。

目录

1 什么是RPC

2 RPC 使用的步骤

3 RPC相关函数

4 代码实现

4.1 服务端代码实现

4.2客户端代码实现

4.3程序实现结果


1 什么是RPC


Remote Procedure Call Protocol –远程过程调用协议!

IPC:进程间通信

RPC:远程进程通信 — 应用层协议(http协议同层),底层用TCP实现。

  • 理解RPC:像调用本地函数一样,去调用远程函数。通过rpc协议,传递:函数名,函数参数。达到在本地,调用远端函数,得返回值到本地的目标。
  • 为什么微服务要使用RPC:
  1. 每个服务都被封转成进程,彼此“独立”。
  2. 进程与进程之间,可以使用不同的语言实现。

2 RPC 使用的步骤


服务端:

  1. 注册rpc服务对象。给对象绑定方法(1,定义类,2,绑定类方法)。

rpc.RegisterNmae(“服务名:”,回调对象)

  1. 创建监听器。

listener,err:=net.Listen()

  1. 建立连接。

conn,err:=listener.Accept()

  1. 将连接绑定rpc服务。

rpc.ServerConn(conn)

客户端:

  1. 用rpc连接服务器。rpc.Dial()

conn,err:=rpc.Dial()

  1. 调用远程函数。

conn.Call(“服务名.方法名”,传入参数,传出参数)

3 RPC相关函数


 1,注册rpc服务

func(server *Server) RegistName(name string ,rcvr interface{}) error

参数1 :服务名,字符串类型

参数2 :对应rpc对象,该对象绑定方法要满足以下条件:

  1. 方法必须是导出的 –包外可见。首字母大写
  2. 方法必须两个参数,都是导出类型,内建类型 
  3. 方法的第二个参数必须是“指针”(传出参数)
  4. 方法只有一个error 接口类型的 返回值

如:

type World struct {

}

方法:

s *Wofunc(thirld) HelloWorld (name string,resp *string) error {

}

rpc.RegisterName(“服务名”,new(World))

2,绑定rpc服务

 func (server *Server) ServerConn(conn io.ReadWriteCloser)

    conn:成功建立好连接的:socket — conn

3,调用远程函数

func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error

serviceMethod:“服务名.方法名”

args:传入参数。方法需要的数据。

reply:传出参数。定义 var 变量,&变量名  完成传参。

4 代码实现

4.1 服务端代码实现

package main

import (
	"fmt"
	"net"
	"net/rpc"
)

type World struct {
}

//绑定类方法

func (this *World) HelloWorld(name string, resp *string) error {
	*resp = name + "你好!"
	return nil
}

func main() {
	//1,注册rpc服务,绑定对象方法
	err := rpc.RegisterName("hello", new(World))
	if err != nil {
		fmt.Println("注册rpc服务失败!", err)
		return
	}
	//2,设置监听
	listener, err := net.Listen("tcp", "127.0.0.1:8800")
	if err != nil {
		fmt.Println("net.Listen err:", err)
		return
	}
	defer listener.Close()

	fmt.Println("开始监听...")

	//3,建立连接
	conn, err := listener.Accept()
	if err != nil {
		fmt.Println("listener.Accept err:", err)
		return
	}
	defer conn.Close()
	fmt.Println("连接成功!")
	//4,绑定服务
	rpc.ServeConn(conn)

}

4

.2客户端代码实现

package main

import (
	"fmt"
	"net/rpc"
)

func main() {
	//1,用rpc连接服务器--Dial()
	conn, err := rpc.Dial("tcp", "127.0.0.1:8800")
	if err != nil {
		fmt.Println("rpc.Dial err:", err)
		return
	}
	defer conn.Close()
	fmt.Println("建立连接成功")
	//2,调用远程函数
	var reply string //接收函数返回值
	err = conn.Call("hello.HelloWorld", "李白", &reply)
	if err != nil {
		fmt.Println("conn.Call err:", err)
		return
	}
	fmt.Println(reply)
}

4.3程序实现结果

服务端

go语言微服务之RPC协议[通俗易懂]

客户端

go语言微服务之RPC协议[通俗易懂]

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/144507.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • GSLB算法

    GSLB算法1)基于流量的负载均衡算法:主要采用负反馈的原理来控制各个POP节点上的流量,负反馈是一种基于偏差的调度算法.2)同时基于往返时间和流量的负载均衡算法:要考虑的负载均衡策略有两个:一个是用户访问POP节点的往返时间,另一个是流量负载,这两个均衡策略同时使用来保证GSLB将用户访问调度到合适节点…

  • h2数据库的使用_h2数据库查看数据

    h2数据库的使用_h2数据库查看数据h2dh​​​​​​​ArchiveDownloads1h2数据库的下载地址2.H2软件包目录结构h2 |—bin ||—h2-1.1.116.jar  //H2数据库的jar包(驱动也在里面) ||—h2.bat  //Windows控制台启动脚本 ||—h2.sh  //Linux控制台启动脚本 ||—h2w.bat  //Windows控制台启动脚本(不带黑屏窗口) |—docs  //H2数据库的帮助文档(内有H2…

  • OpenGL的glPushMatrix()和glPopMatrix()矩阵栈顶操作函数详解「建议收藏」

    OpenGL中图形绘制后,往往需要一系列的变换来达到用户的目的,而这种变换实现的原理是又通过矩阵进行操作的。opengl中的变换一般包括视图变换、模型变换、投影变换等,在每次变换后,opengl将会呈现一种新的状态(这也就是我们为什么会成其为状态机)。    有时候在经过一些变换后我们想回到原来的状态,就像我们谈恋爱一样,换来换去还是感觉初恋好,怎么办?强大的opengl就帮我们提

  • 深入解析Linux Platform_device 及驱动

    深入解析Linux Platform_device 及驱动[导读]前文分析了Linux设备驱动的驱动模型,本文来聊聊Platform_driver/Platform_device这个类。做嵌入式Linux的驱动,这个也是绕不开的,所以来学习分析总结一下。

  • Redis主从复制原理以及常见问题

    相信很多小伙伴都已经配置过主从复制,但是对于redis主从复制的工作流程和常见问题很多都没有深入的了解。咔咔这次用时俩天时间给大家整理一份redis主从复制的全部知识点。主从复制(一)什么是redis主从复制?(二)为什么需要redis主从复制?(三)主从复制的作用(一)什么是redis主从复制?主从复制就是现在有俩台redis服务器,把一台redis的数据同步到另一台redis数据库上。前者称之为主节点(master),后者为从节点(slave)。数据是只能master往slave同步单向。但.

  • js生成二维码_js生成二维码并保存

    js生成二维码_js生成二维码并保存js生成二维码一、一个简单的示例前段时间项目中需要开发扫描二维码查看信息的功能,在网上查了一些资料,把用过的方法进行总结需要导入一个qrcode的js插件。一、一个简单的示例如下:(仅供参考)<%–CreatedbyIntelliJIDEA.User:ASUSauthor:xumzDate:2021/2/27Time:10:33搬运请备注TochangethistemplateuseFile|Settings|Fil

    2022年10月18日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号