golang文件传输服务
时间:2022-05-05
本文章向大家介绍golang文件传输服务,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本篇介绍一个完整的golang文件传输服务器。
网络使用的框架如上篇介绍,这里就不再复述.
首先定义3个命令码:
const (
request_file = 1
file_size = 2
transfering = 3)
request_file用于请求文件传输,附带的命令参数是文件key.
file_size用于通告客户端文件的大小.
transfering用于传输文件内容,附带参数是文件内容的二进制数据.
服务器的文件配置示例
../learnyouhaskell.pdf=haskell
../golang.1.1.2.chm=golang
../NodeJS.pdf=NodeJS
上面的文件配置了3个文件可供传输=左边是文件路径,右边是请求文件时使用的key.
服务器启动时首先调用loadfile将文件导入到内存中,然后根据定义的key,将文件内容插入到字典filemap中:
func loadfile(){ //从配置导入文件
F,err := os.Open("./config.txt") if err != nil {
fmt.Printf("config.txt open failedn") return
}
filemap = make(map[string][]byte)
bufferReader := bufio.NewReader(F)
eof := false
for !eof {
line,err := bufferReader.ReadString('n') if err == io.EOF{
err = nil
eof = true
}else if err != nil{
fmt.Printf("parse file errorn") return
} if len(line) > 1 {
line = line[0:len(line)-1]//drop 'n'
fileconfig := strings.Split(line,"=") if len(fileconfig) == 2 {
buf, err := ioutil.ReadFile(fileconfig[0]) if err != nil {
fmt.Printf("%s load errorn",fileconfig[0])
}else{
filemap[fileconfig[1]] = buf
fmt.Printf("%s load success,key %sn",fileconfig[0],fileconfig[1])
}
}
}
} if filemap["golang"] == nil {
fmt.Printf("golang not foundn")
}
fmt.Printf("loadfile finishn")
}
接着是服务其的packet_handler:
func process_client(session *tcpsession.Tcpsession,rpk *packet.Rpacket){
cmd,_ := rpk.Uint16() if cmd == request_file { if session.Ud() != nil {
fmt.Printf("already in transfer sessionn")
}else
{
filename,_ := rpk.String()
filecontent := filemap[filename] if filecontent == nil {
fmt.Printf("%s not foundn",filename)
session.Close()
}else{
fmt.Printf("request file %sn",filename)
tsession := &transfer_session{filecontent:filecontent,ridx:0}
session.SetUd(tsession)
wpk := packet.NewWpacket(packet.NewByteBuffer(64),false)
wpk.PutUint16(file_size)
wpk.PutUint32(uint32(len(filecontent)))
session.Send(wpk,nil)
tsession.send_file(session)
}
}
}else{
fmt.Printf("cmd error,%dn",cmd)
session.Close()
}
}
如果收到的消息是requestfile,首先查看请求的文件是否存在,如果存在则创建一个文件传输过程transfersession,
并将它与tcpsession绑定,然后发出一个文件大小通告包,紧接着立即调用send_file开始发送文件内容.
func (this *transfer_session)send_file(session *tcpsession.Tcpsession){
remain := len(this.filecontent) - this.ridx
sendsize := 0
if remain >= 16000 {
sendsize = 16000
}else{
sendsize = remain
}
wpk := packet.NewWpacket(packet.NewByteBuffer(uint32(sendsize)),false)
wpk.PutUint16(transfering)
wpk.PutBinary(this.filecontent[this.ridx:this.ridx+sendsize])
session.Send(wpk,send_finish)
this.ridx += sendsize
}
sendfile中根据当前发送位置判断还有多少内容需要发送,如果剩余内容小于16000字节就将所剩数据一次性
发出,否则 发送16000字节的数据,并调整发送位置。注意到Send函数带了一个sendfinish函数作为参数,其作用
是当数据包发送 完成后回调send_finish函数.
func send_finish (s interface{},wpk *packet.Wpacket){
session := s.(*tcpsession.Tcpsession)
tsession := session.Ud().(*transfer_session) if tsession.check_finish(){
session.Close() return
}
tsession.send_file(session)
}
send_finish的作用是判断文件是否已经发送完,如果发完断开连接,否则接着发送剩余部分.
总结一下,golang用来编写服务器应用还是相当方便的,很多细节问题在语言层面或系统库里已经帮你解决掉了
,可以将主要的 精力放在逻辑的处理上.
本文来自:博客园
感谢作者:sniperHW
查看原文:golang文件传输服务
- 2018年物联网发展趋势
- Silverlight初级教程-概述
- WCF的Binding模型之四:信道工厂(Channel Factory)
- 如何做一个好的前端重构工程师
- 云计算是否真的对企业来说无所不能?
- 科协带你开个2017年科技世界的总结会!
- 基于StockRanker算法的机器学习量化策略
- Enterprise Library深入解析与灵活应用(6):自己动手创建迷你版AOP框架
- 交易费用过高的比特币还能成为“未来货币”吗?
- 应用大数据,做好技术成果市场价值评估
- Linux和Windows的换行符
- 行业数据重要性不用多说,呕心整理分享(2)
- 云计算如何在银行业务发挥作用?
- SNH48 要推出定制 AI 形象,和初音未来有什么不同?
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- CVE-2020-0796漏洞复现(RCE)
- Jenkins持续集成平台安装
- mysql架构备份之M-S-S级联复制
- Docker构建lnmp环境部署typecho
- MANJARO KDE安装配置(已换Arch Linux,此贴可能废弃)
- [数据库推荐]qPCR引物设计与评价
- markdown数学公式
- C++核心准则T.2:使用模板表现可以适用于多种参数类型的算法
- C++核心准则T.3:使用模板表现容器和范围
- Markdown的时序图、流程图、和甘特图+Hexo的相关配置
- 记一次Fcitx5的安装
- 解决KDE下KDE Wallet重装系统后每次登陆需要输入密码
- KDE下完美的Unity桌面体验,扔掉active window control
- C++核心准则T.5:结合使用泛型和面向对象技术应该增强它们的效果而不是成本
- C++核心准则T.10:为所有的模板参数定义概念