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)


相关推荐

  • Map的有序性_有序的map集合有哪些

    Map的有序性_有序的map集合有哪些//使用LinkedHashMap代替无序的HashMap实现publicstaticvoidmain(String[]args){/***Constructsanemptyinsertion-ordered<tt>LinkedHashMap</tt>instance*withthedefaul…

  • sql镶嵌查询_标准SQL嵌套查询语句[通俗易懂]

    sql镶嵌查询_标准SQL嵌套查询语句[通俗易懂]展开全部1、简单子查询62616964757a686964616fe78988e69d8331333433626530selectname,agefrompersonwhereage>(selectagefrompersonwherename=’百度’)2、in嵌套查询selectnamefrompersonwherecountryidin(selectco…

  • 卡尔曼滤波系列——(一)标准卡尔曼滤波[通俗易懂]

    卡尔曼滤波系列——(一)标准卡尔曼滤波[通俗易懂]卡尔曼滤波(KalmanFilter)是一种利用线性系统状态方程,利用对系统的观测数据,对系统状态进行最优估计的算法。由于观测数据受到系统中的噪声和干扰的影响,所以系统状态的估计过程也可看作是滤波过程。应用场景之一有利用传感器跟踪感兴趣目标的位置,传感器获取的目标距离、速度、方位角等观测值往往含有噪声。卡尔曼滤波利用目标的动态信息与观测结果相结合,抑制噪声的影响,从而获得一个关于目标位置更准确的估计,这个估计可以是对当前目标位置的估计(滤波),也可以是对于将来位置的估计(预测),也可以是对过去位置的估计(

  • 模式的分类

    模式的分类模式的分类

  • linux(dpkg 命令用法)[通俗易懂]

    linux(dpkg 命令用法)[通俗易懂]linux环境安装labview

  • 计算机按位取反[通俗易懂]

    计算机按位取反[通俗易懂]取反过程1.转成二进制2.取补码3.补码的反码(符号位不变)4.反码加+1可以通过原码、反码和补码三者的含义及关系来介绍三者之间的换算关系:1、原码原码就是符号位加上真值的绝对值,即用第一位表示符号,其余位表示值。比如如果是8位二进制:[+1]原=00000001[-1]原=10000001第一位是符号位。2、反码

发表回复

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

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