rust学习基于tokio_actor聊天服务器实战(一 )

前言
tokio是Rust中使用最广泛的异步Runtime，它性能高、功能丰富、便于使用，是使用Rust实现高并发不可不学的一个框架
Actor 背后的基本思想是产生一个独立的任务，该任务独立于程序的其他部分执行某些工作。 通常，这些参与者通过使用消息传递信道与程序的其余部分进行通信。 由于每个 Actor 独立运行，因此使用它们设计的程序自然是并行的。 Actor 的一个常见用法是为 Actor 分配你要共享的某些资源的专有所有权，然后让其他任务通过与 Actor 通信来间接访问彼此的资源。 例如，如果要实现聊天服务器，则可以为每个连接生成一个任务，并在其他任务之间路由一个聊天消息的主任务。 十分有用，因为主任务可以避免必须处理网络IO，而连接任务可以专门处理网络IO；
为什么一定要用actor,这里只是仿照go项目里一部分，go 用的就是actor;

1：环境
rust1.75
ide rustrover64

2:设计及实现
这里使用类似单点登录模式，
useractor
先看go的
在这里插入图片描述
在这里插入图片描述
一共3个协程/future
接受网络消息 一个协程/future
发送网络消息 一个协程/future
逻辑处理 一个协程/future
协程/future间通信 直接用mpsc

world actor/accmgr 管理useractor 登录，踢人，广播等

一共1个协程/future 处理逻辑消息
在这里插入图片描述

rust 版
useractor
说明 receiver: mpsc::UnboundedReceiver, logic future 接受消息并处理
sendclient: mpsc::UnboundedSender 发送消息给 网络future 从而发送给前端
worldsender: mpsc::UnboundedSender, 跟world actor 通信接口

pub enum ActorMessage {
    synmsgwaitrep {
        //同步等待回复
        //需要发送到别处等到别处返回结果，类似于同步操作，只是异步执行的  //oneshot  spsc
        respond_to: crate::synMsgWaitRep, //同步消息
    },
    wtc_userchann {
        respond_to: crate::userChan_WTC, //
    },
    wtc_msg(sendMsgAndType),
    wtc_forwardmsg(sendMsgAndType), //直接转发 data
    ctw_msg(sendMsgAndType),
    ctc_nettologic_msg(sendMsgAndType), //网络消息 to logic
    ctc_logictonet_msg(sendMsgAndType), //logic to net  send
    ctc_signal_event(signalType),
    ctw_signal_event(signalType),
    wtc_signal_event(signalType),
    wtc_getChan_msg(userChannChann),
}
pub struct MyUserActor {
    connid: ConnectID,
    userid: UserID,
    username: String,
    guildid: GuildID,
    userstate: Arc<AtomicU8>,
    receiver: mpsc::UnboundedReceiver<ActorMessage>,
    sendclient: mpsc::UnboundedSender<VU8>,
    worldsender: mpsc::UnboundedSender<ActorMessage>,
    msgmask: u32,
    lasttime: [u32; ChatChannel_Num],
}

world actor
mpscrecv: mpsc::UnboundedReceiver, 接收ActorMessage logic future
chanchan: mpsc::UnboundedReceiver, 接受 ActorMessage2 logic future

pub enum ActorMessage2 {
    synmsgwaitrep {
        //同步等待回复
        //需要发送到别处等到别处返回结果，类似于同步操作，只是异步执行的  //oneshot  spsc
        respond_to: crate::synMsgWaitRep2, //同步消息
    },

    ctw_userhann {
        respond_to: crate::userChan_CTW, //同步消息
    },
}
pub struct userSendChanActorMessage {
    pub(crate) chanchan: Option<mpsc::UnboundedSender<ActorMessage>>,
    pub(crate) username: String,
    pub(crate) userguildid: GuildID,
    pub(crate) connectid: ConnectID,
    pub(crate) chanState: Arc<AtomicU8>, //user 状态
}

pub struct worldActor {
    sharestate: Arc<AtomicU8>,
    mpscrecv: mpsc::UnboundedReceiver<ActorMessage>,
    chanchan: mpsc::UnboundedReceiver<ActorMessage2>,
    usermap: HashMap<UserID, userChan_world>,
    namemap: HashMap<String, UserID>,
    guildmap: HashMap<GuildID, HashSet<UserID>>,
    maxonlinerole: u32,
}

 async fn run(mut self) {
        // let logic_handle = self.handle_logic(recv);
        loop {
            tokio::select! {
                recvmsg= self.mpscrecv.recv()=> {
                    if let Some(actmsg) = recvmsg {
                        self.handle_logic(actmsg).await ;
                    }
                }
                recvmsgchan= self.chanchan.recv()=>{
                    if let Some(actmsg) = recvmsgchan {
                        self.handle_logic2(actmsg).await ;
                    }
                }
                _=tokio::time::sleep(Duration::from_millis(1000*8)) =>{

                }
            }
        } //end loop
    }

同步的方式的异步 go 很简单， rust go 上多一点点
go
在这里插入图片描述
rust
在这里插入图片描述

在这里插入图片描述

网络跟逻辑分开，这样 挤号，只需要把 logic future 里 sendclient mpsc 更新， 把网络 to logic mpsc 更新 及一些 状态重置下 即可，无需重新加载现有useractor 里的信息
类试单点登录 对于聊天服务器来说 ，只需要 角色进入后，由logic服 ase 对称加密(密钥及盐，logic 服 chat 服 共享/配置，共享方式自行决定）或 非对称(ECC) 等都可以，加密的token 由前端发送 给chat 服，chat 解密 得到 相应信息 并验证有效性 参考加解密验证用户的合法性

3:测试
前端简单用go 写了个

var origin = "http://192.168.1.32:8080"
var url = "wss://192.168.1.32:8080/websocket"
func GetProtoMsgID(data []byte) uint32 {
	var sMsgID uint16 = uint16(uint8(data[3] & 0x7f))
	if (uint8(data[3]) & 0x80) > 0 {
		sMsgID += (uint16(data[4]) & 0x7f) << 7
	}
	return uint32(sMsgID)
}

func  sendMsg(ws *websocket.Conn,pb proto.Message) {
	if ws != nil {
		if data, err2 := proto.Marshal(pb); err2 != nil {
			log.Printf("SendMessage pb=%v err2=%v \n", pb, err2)
		} else {
			if err4 := websocket.Message.Send(ws, data); err4 != nil {
				log.Printf("send error =%v \n", err4)
			}
		}
	}
}

func doLogicMsg(data []byte)  {
	msgId := GetProtoMsgID(data)
	fmt.Printf("msgid=%v",msgId)
	switch msgId {
	case uint32(chatproto.CHATMSG_CHC_Login_Rep):
		{
			loginReq := &chatproto.ChatMessageLoginRep{}
			if err := proto.Unmarshal(data, loginReq); err != nil {

			} else {
				fmt.Printf("CHATMSG_CHC_Login_Rep =%v \n",loginReq.Res)
			}
		}
	case uint32(chatproto.CHATMSG_CCH_Chat_Rep):
		{
			chatrep := &chatproto.ChatMessageChatRep{}
			if err := proto.Unmarshal(data, chatrep); err != nil {

			} else {
				fmt.Printf("CHATMSG_CCH_Chat_Rep =%v \n",chatrep.Res)
			}
		}
	case uint32(chatproto.CHATMSG_CHC_Notify_Chat):
		{
			chatmsg := &chatproto.ChatMessageNotifyChat{}
			if err := proto.Unmarshal(data, chatmsg); err != nil {

			} else {
				fmt.Printf("CHATMSG_CHC_Notify_Chat =%v fromuserid=%v text=%v \n",chatmsg.Chattype,chatmsg.Senderid,chatmsg.Strcontext)
			}
		}
	}

}
func getTimestamp() uint32 {
	return  uint32(time.Now().UTC().Unix());
}

func main(){
	//if os.Args[0]
	userid :=  getTimestamp()
	guildid := uint32(0)
	if len(os.Args) > 1 {
		if s,e := strconv.Atoi(os.Args[1]);e ==nil {
			userid = uint32(s)
		}
	}
	if len(os.Args) > 2 {
		if s,e := strconv.Atoi(os.Args[2]);e ==nil {
			guildid = uint32(s)
		}
	}

	ws, err := websocket.Dial(url, "", origin)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("userid=%v guild=%v \n",userid,guildid)
	{
		msg := new(chatproto.ChatMessageLoginReq)
		msg.Msghead = &chatproto.ChatMessageHead{uint32(chatproto.CHATMSG_CCH_Login_Req), 1}
		msg.Userid = userid
		msg.Username = "name_"+strconv.Itoa(int(userid))
		msg.Guildid = guildid
		msg.Tokenmd5 = "md5"
		msg.Tokenstr = "Tokenstr"

		sendMsg(ws, msg)
	}
	disflag :=  false
	{
		go func() {
			for{
				buf := make([]byte, 1024*4)
				err := websocket.Message.Receive(ws, &buf)
				if err != nil {
					//log.Printf("websocket.Message.Receive err=%v  ---%s\n", err,self.getAccName())
					disflag = true
					return
				}

				if len(buf) >= 4 {

					doLogicMsg(buf)

					//self.msgQue.PostUserMessage(&ReceiveNetMsg{buf})
				} else {
					log.Printf("[error]recv data=%v \n", buf)
					return
				}
			}

		}()

	}
	time.Sleep(time.Second*3)

	//pub enum  ChatChannel{
	//	ChatChannel_NONE=0,
	//	ChatChannel_NORMAL,
	//	ChatChannel_GUILD,
	//	ChatChannel_WORLD,
	//	ChatChannel_ALL,
	//}


	{
		sendcount := uint32(1)
		num := uint32(0)
		msg := new(chatproto.ChatMessageChatReq)
		msg.Msghead = &chatproto.ChatMessageHead{uint32(chatproto.CHATMSG_CCH_Chat_Req), 1}
		msg.Chattype = 1
		msg.Context ="normal chat "+ strconv.Itoa(int(num))

		for {
			if disflag { //脏数据
				break
			}
			sendMsg(ws, msg)
			time.Sleep(time.Second*10)
			num++
			m := num % 3 +1
			msg.Chattype = uint32(m)
			msg.Context ="normal chat "+ strconv.Itoa(int(sendcount))
			fmt.Printf("[%v][%v] send chattype=%v \n",sendcount,getTimestamp(),msg.Chattype)
			sendcount++
			//if m == 3  {
			//	time.Sleep(time.Second*10)
			//}
		}
	}

	ws.Close()//关闭连接
	fmt.Printf("client exit\n")
}

相互挤号测试
在这里插入图片描述
4:DEMO工程 后续完善了如有需要再上传(当前只能说基本上跑起来)
如果觉得有用，麻烦点个赞，加个收藏

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/360459.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

如何使用postman进行接口自动化测试？

如何使用postman进行接口自动化测试？

1、什么是自动化测试&#xff1f; 把人对软件的测试行为转化为由机器执行测试行为的一种实践。 例如GUI自动化测试&#xff0c;模拟人去操作软件界面&#xff0c;把人从简单重复的劳动中解放出来&#xff0c;本质是用代码去测试另一段代码&#xff0c;属于一种软件开发工作&a…
阅读更多...
TRIZ：打破便携与功能矛盾，卫星通信领域的新曙光！

TRIZ：打破便携与功能矛盾，卫星通信领域的新曙光！

在当今的卫星通信领域&#xff0c;便携性与功能性的矛盾一直是困扰着研发人员的一大难题。如何在保持设备便携的同时&#xff0c;确保其功能的完善和稳定&#xff0c;成为了业界关注的焦点。而解决这一问题的关键&#xff0c;或许正隐藏在TRIZ这一强大的创新方法论之中。 TRIZ&…
阅读更多...
【PyCharm教程】PyCharm 安装、卸载和升级包

【PyCharm教程】PyCharm 安装、卸载和升级包

PyCharm 为特定的 Python 解释器提供了安装、卸载和升级 Python 包的方法。默认情况下&#xff0c;PyCharm 使用 pip 来管理项目包。对于 Conda 环境&#xff0c;您可以使用conda 包管理器。 在 PyCharm 中&#xff0c;您可以在Python 包工具窗口和 Python 解释器Settings/Pre…
阅读更多...
暴雨受邀出席太原市人工智能行业协会年度大会

暴雨受邀出席太原市人工智能行业协会年度大会

2024年1月26日&#xff0c;太原市人工智能行业协会第二届二次会员大会暨2024年年会成功召开。太原市委、市工商联、市大数据应用中心、市政协经济委员会以及太原市科技局的专家领导&#xff0c;与三百多名来自各行业的人工智能企业家和协会会员一同参加了本次盛会&#xff0c;共…
阅读更多...
（十一）springboot实战——springboot3下关于WebFlux项目的一些常用功能整合

（十一）springboot实战——springboot3下关于WebFlux项目的一些常用功能整合

前言 本节内容主要是对webflux项目一些常用功能的介绍&#xff0c;例如系统集成swagger接口文档&#xff0c;方便接口测试以及前后端项目联调测试&#xff1b;使用actuator完成系统各种指标的监控功能&#xff1b;系统使用logback日志框架完成项目日志的收集&#xff1b;使用过…
阅读更多...
项目：博客

项目：博客

1. 运行环境&#xff1a; 主机 主机名 系统 服务 192.168.223.129 Server_Web Linux Web 192.168.48.131 Server-NFS-DNS Linux NFS/DNS 2. 基础配置 配置主机名&#xff0c;静态IP地址 开启防火墙并配置 部分开启SElinux并配置 服务器之间使用同ntp.aliyun.com进行…
阅读更多...
eBay测评自养号下单需要满足哪些技术要求？养号优势有哪些？

eBay测评自养号下单需要满足哪些技术要求？养号优势有哪些？

自养号测评环境搭建系统涉及几个主要环节&#xff1a; 1.系统环境&#xff1a;用于登录和管理多个账号&#xff0c;需具备防关联功能&#xff0c;每个账号使用独立IP&#xff0c;确保完全隔离无关联问题。 2.高质量网络环境&#xff1a;需要国外家庭住宅IP&#xff0c;纯净度…
阅读更多...
开发者带你了解山海鲸智慧社区解决方案

开发者带你了解山海鲸智慧社区解决方案

作为山海鲸可视化软件的开发者&#xff0c;我们深知在智慧社区建设中&#xff0c;数据可视化对于提升社区管理效率和居民生活品质的重要性。因此在提供人人都能免费使用的产品基础上&#xff0c;特结合山海鲸可视化软件优势打造智慧社区解决方案&#xff0c;本文将为您详细介绍…
阅读更多...
sketchup草图大师模型网怎么样？

sketchup草图大师模型网怎么样？

SketchUp草图大师模型网是一个提供SketchUp模型下载和分享的平台&#xff0c;如建e网等&#xff0c;用户可以在上面找到大量的SU模型&#xff0c;并学习一些SketchUp的使用技巧。该网站模型种类丰富&#xff0c;涵盖了建筑、景观、室内等不同领域&#xff0c;同时也有一些教程&…
阅读更多...
6天获邀请函|食品科学老师赴英国Quadram研究所访学交流

6天获邀请函|食品科学老师赴英国Quadram研究所访学交流

C老师拟申报CSC国家公派访问学者项目&#xff0c;因DIY申请无果且申报期临近而求助于我们。依本人要求&#xff0c;我们迅速开展了全方位申请&#xff0c;几天内获得近十个反馈&#xff0c;最终其选择了不需要面试且不收板凳费的英国Quadram研究所&#xff0c;此时距离开展申请…
阅读更多...
2024新鲜出炉 Java集合常见面试题总结(上)

2024新鲜出炉 Java集合常见面试题总结(上)

2024新鲜出炉 Java集合常见面试题总结(上) 文章目录 2024新鲜出炉 Java集合常见面试题总结(上)集合概述Java 集合概览说说 List, Set, Queue, Map 四者的区别&#xff1f;集合框架底层数据结构总结ListSetQueueMap 如何选用集合?为什么要使用集合&#xff1f; ListArrayList 和…
阅读更多...
SOME/IP SD 协议介绍(五）使用SOME/IP-SD宣布非SOME/IP协议的协议。

SOME/IP SD 协议介绍(五）使用SOME/IP-SD宣布非SOME/IP协议的协议。

使用SOME/IP-SD宣布非SOME/IP协议的协议。 除了SOME/IP之外&#xff0c;车辆内部还使用其他通信协议&#xff0c;例如用于网络管理、诊断或闪存更新。这些通信协议可能需要传递服务实例或具有事件组。 对于非SOME/IP协议&#xff0c;应使用特殊的服务ID&#xff0c;并使用配置…
阅读更多...
最新盘点！2024年最好用的十大进销存管理系统

最新盘点！2024年最好用的十大进销存管理系统

深度盘点国内外十大进销存管理系统&#xff1a;简道云进销存、Oracle NetSuite、金蝶精斗云、用友、浪潮云进销存、傻瓜进销存、旺店通、生意专家、QT9、Linnworks。 进销存指的是企业管理过程中采购&#xff08;进&#xff09;——入库&#xff08;存&#xff09;——销售&am…
阅读更多...
20240127在ubuntu20.04.6下配置whisper

20240127在ubuntu20.04.6下配置whisper

20240131在ubuntu20.04.6下配置whisper 2024/1/31 15:48 首先你要有一张NVIDIA的显卡&#xff0c;比如我用的PDD拼多多的二手GTX1080显卡。【并且极其可能是矿卡&#xff01;】800&#xffe5; 2、请正确安装好NVIDIA最新的驱动程序和CUDA。可选安装&#xff01; 3、配置whispe…
阅读更多...
备战蓝桥杯---数据结构与STL应用（入门3）

备战蓝桥杯---数据结构与STL应用（入门3）

我们先来一道题作为过渡&#xff1a; 我们只需枚举n,选出左右第一个小于它高度的坐标即可&#xff0c;于是我们可以用两个方向的优先队列来维护&#xff0c;下面是AC代码&#xff1a; #include<bits/stdc.h> using namespace std; #define int long long int n; struct …
阅读更多...
基于ssm和微信小程序的健身房私教预约管理系统

基于ssm和微信小程序的健身房私教预约管理系统

文章目录 项目介绍主要功能截图&#xff1a;部分代码展示设计总结项目获取方式 &#x1f345; 作者主页&#xff1a;超级无敌暴龙战士塔塔开 &#x1f345; 简介&#xff1a;Java领域优质创作者&#x1f3c6;、 简历模板、学习资料、面试题库【关注我&#xff0c;都给你】 &…
阅读更多...
Word莫名其妙开启兼容模式将其永久取消的方法

Word莫名其妙开启兼容模式将其永久取消的方法

这是因为Word模板文件被意外更改了 找到Word模板文件&#xff0c;目录在C:\Users\15976\AppData\Roaming\Microsoft\Templates 15976替换成你自己的用户名&#xff0c;不确定的就先点进C/Users看一看&#xff0c; AppData是隐藏文件夹&#xff0c;显示隐藏文件夹才能看见&am…
阅读更多...
MySQL备份和恢复（二）mysqldump

MySQL备份和恢复（二）mysqldump

注意&#xff1a;mysqldump是完全备份 一、mysqldump备份命令 1、 备份数据库 含创建库语句 &#xff08;1&#xff09;备份指定数据库 完全备份一个或多个完整的库&#xff0c; mysqldump -uroot -p[密码] --databases 库名1 [库名2].. >/备份路径/备份文件名.sql#导出…
阅读更多...
安泰高压放大器电路设计方案是什么

安泰高压放大器电路设计方案是什么

高压放大器是电子设备中常用的一种放大器类型&#xff0c;用于将低电压信号放大到高电压输出。本文将介绍高压放大器电路设计的基本原理和方案&#xff0c;涵盖关键设计考虑因素以及常用的电路拓扑结构。 一、设计考虑因素 放大倍数&#xff1a;高压放大器的设计首要考虑因素是…
阅读更多...
【海贼王编程冒险 - C语言海上篇】自定义类型：结构体，枚举，联合怎样定义？如何使用？

【海贼王编程冒险 - C语言海上篇】自定义类型：结构体，枚举，联合怎样定义？如何使用？

目录 1 -> 结构体的声明 1.1 -> 结构的基础知识 1.2 -> 结构的声明 1.3 -> 特殊的声明 1.4 -> 结构的自引用 1.5 -> 结构体变量的定义与初始化 1.6 -> 结构体内存对齐 1.7 -> 修改默认对齐数 1.8 -> 结构体传参 2 -> 位段 2.1 -> …
阅读更多...
最新文章

Copyright @ 2022~2023