博客地址

golang，tcp服务——客户端源码下载

全局变量，用于储存聊天历史记录

var MSGS []string

main.go文件

func main() {port := "39003"Listen, err := net.Listen("tcp", ":"+port)if err != nil {fmt.Println(err)}fmt.Println("Chatroom begin,listen port:", port)connMap := make(map[net.Conn]string)for {conn, err := Listen.Accept()defer conn.Close()if err != nil {fmt.Println(err.Error())continue}connMap[conn] = conn.RemoteAddr().String()//提醒用户上线notice(conn)//处理用户操作go HandlerConn(conn, connMap)}
}

处理每一个连接conn操作

func HandlerConn(conn net.Conn, connMap map[net.Conn]string) {buf := make([]byte, 1024)for {n, err := conn.Read(buf)if err != nil {// fmt.Println("conn数据读取失败" + err.Error())return}msg := strings.Trim(string(buf[:n]), "\r\n")fmt.Printf("msg: %v\n", msg)if strings.Contains(msg, "firstname") {name := strings.ReplaceAll(msg, "firstname", "")fisrtrename(conn, connMap, name)broadcastUserOnline(conn, connMap, name+"用户上线")fmt.Println(name + "用户上线")continue}handlerMsg(conn, connMap, msg)}
}

处理连接操作后，处理消息

消息操作，分为broadcast广播消息以及系统操作

当前支持操作，修改用户名，查看在线用户，查看历史聊天记录

func handlerMsg(conn net.Conn, connMap map[net.Conn]string, msg string) {parseArr := strings.Split(msg, "$")//判断消息是否为操作if len(parseArr) > 1 && parseArr[0] == "do" {//是——执行操作switch parseArr[1] {case "rename":{if len(parseArr) == 3 {name := parseArr[2]rename(conn, connMap, name)} else {returnerr(conn)}}case "list":{if len(parseArr) == 2 {list(conn, connMap)}}case "hy":{if len(parseArr) == 2 {getHistory(conn)}}default:{returnerr(conn)}}} else {//否——广播信息broadcast(conn, connMap, msg)}}

操作函数——获取聊天记录

func getHistory(conn net.Conn) {allmsg := ""for num, msg := range MSGS {str := fmt.Sprintf("\n      *******第%d条*******", num+1)msg = str + msgallmsg += msg}conn.Write([]byte(allmsg))
}
func save10Msg(msg string) {MSGS = append(MSGS, msg)// MSGS = MSGS[10:]
}

操作函数——获取在线列表

func list(conn net.Conn, connMap map[net.Conn]string) {var listname string = ""for connCur, name := range connMap {_, err := connCur.Write([]byte("false"))if err != nil {delete(connMap, connCur)continue} else {fmt.Printf("name: %v\n", name)}listname = listname + name + "\n"}conn.Write([]byte(listname))}

操作函数——修改用户名

func rename(conn net.Conn, connMap map[net.Conn]string, name string) {for connCur := range connMap {if connCur == conn {connMap[conn] = namerecmsg := "操作成功，修改name为：" + name + "\n"conn.Write([]byte(recmsg))}}
}

广播消息操作

func broadcast(conn net.Conn, connMap map[net.Conn]string, msg string) {for connCur := range connMap {if conn == connCur {up := "\n==========历史信息============\n"msg := "time:" + time.Now().Format(" 15:04:05 ") + "\n" + "name:" + connMap[conn] + "\n" + "msg:" + msg + "\n"down := "===========历史信息===========\n\n"save10Msg(up + msg + down)continue}up := "\n==========历史信息============\n"msg := "time:" + time.Now().Format(" 15:04:05 ") + "\n" + "name:" + connMap[conn] + "\n" + "msg:" + msg + "\n"down := "===========历史信息===========\n\n"save10Msg(up + msg + down)str := []byte(msg)_, err := connCur.Write(str)if err != nil {// fmt.Println("broadcast fail", err.Error())delete(connMap, connCur)continue}}}

其他函数①——提醒用户上线

func broadcastUserOnline(conn net.Conn, connMap map[net.Conn]string, msg string) {for connCur := range connMap {if conn == connCur {continue}fmt.Println("回写内容")str := []byte("time:" + time.Now().Format(" 15:04:05 ") + "\n" + "msg:" + msg + "\n")_, err := connCur.Write(str)if err != nil {// fmt.Println("broadcast fail", err.Error())delete(connMap, connCur)continue}}
}

其他函数②——处理用户名的初始化

func fisrtrename(conn net.Conn, connMap map[net.Conn]string, name string) {for connCur := range connMap {if connCur == conn {connMap[conn] = name}}
}

其他函数③——返回错误信息

func returnerr(conn net.Conn) {errmsg := "参数错误，请重新输入\n"conn.Write([]byte(errmsg))
}

chatroom聊天室—服务端（基于golang）相关推荐

安卓多人聊天室服务端
安卓多人聊天室服务端服务端没有图形界面,直接上代码 package cn.ttw.netProgram.tcp;import java.io.*; import java.net.InetAddre ...
聊天室服务端和客户端的实现
在Linux环境下,实现客户端和服务端之间的信息发送和接收,实现聊天室,可进行文件传送功能. 客户端: #include <sys/types.h> #include <sys/so ...
python与html5搭建聊天室_html5 websocket 新版协议聊天室服务端（python版）
网上找了很多代码都是旧版协议的,研究了很久终于弄清楚了现在发个用新版协议写的服务端代码出来(这个代码是从网上旧版协议改过来的) 最要就是握手协议和发送接受字符的方式变了 # incoding=utf ...
【第99题】JAVA高级技术-网络编程18（简易聊天室13：聊天室服务端)
回城传送–><JAVA筑基100例> 文章目录零.前言一.题目描述二.解题思路三.代码详解多学一个知识点四.推荐专栏五.示例源码下载零.前言今天是学习 JAVA ...
完整的ChatRoom聊天室代码
完整的ChatRoom聊天室代码原创Viki渡清欢发布于2019-04-16 22:37:52 阅读数 537 收藏展开概述上节说到消息粘包和数据不完整的问题未解决,也就是数据传输缓冲区固 ...
NIO框架入门(一)：服务端基于Netty4的UDP双向通信Demo演示
2019独角兽企业重金招聘Python工程师标准>>> 前言 NIO框架的流行,使得开发大并发.高性能的互联网服务端成为可能.这其中最流行的无非就是MINA和Netty了,MINA目 ...
魔坊APP项目-16-种植园、websocket协议、服务端基于socket提供服务（基于房间管理分发信息）、种植园页面展示
种植园我们需要完成的种植园,是一个互动频繁,并且要求有一定即时性的模块,所以如果继续基于http协议开发,那么需要通过ajax发送大量http请求,同时因为http本身属于单向通讯,所以服务端无法主 ...
java web聊天室论文_基于Java网页版聊天室的设计与实现毕业论文含开报告及文献综述.doc...
基于Java网页版聊天室的设计与实现毕业论文含开报告及文献综述本科生毕业论文(设计) 题目: 基于Java网页版聊天室的设计与实现姓名:学院: 理学院专业: 信息与计算科学班级: 信 ...
java web聊天室论文_基于javaweb聊天室.doc
基于javaweb聊天室.doc 南嗦岌凌*4 文(设计) 本科生毕业论题目:基于Java网页版聊天室的设计与实现姓名:陈义旺学院:理学院专业:信息与计算科学班级:信科092 学号: 指导 ...

chatroom聊天室—服务端（基于golang）

博客地址

golang，tcp服务——客户端源码下载

全局变量，用于储存聊天历史记录

main.go文件

处理每一个连接conn操作

处理连接操作后，处理消息

消息操作，分为broadcast广播消息以及系统操作

当前支持操作，修改用户名，查看在线用户，查看历史聊天记录

操作函数——获取聊天记录

操作函数——获取在线列表

操作函数——修改用户名

广播消息操作

其他函数①——提醒用户上线

其他函数②——处理用户名的初始化

其他函数③——返回错误信息

chatroom聊天室—服务端（基于golang）相关推荐

最新文章

热门文章

chatroom聊天室—服务端（基于golang）

博客地址

golang，tcp服务——客户端 源码下载

全局变量，用于储存聊天历史记录

main.go文件

处理每一个连接conn操作

处理连接操作后，处理消息

消息操作，分为broadcast广播消息以及系统操作

当前支持操作，修改用户名，查看在线用户，查看历史聊天记录

操作函数——获取聊天记录

操作函数——获取在线列表

操作函数——修改用户名

广播消息操作

其他函数①——提醒用户上线

其他函数②——处理用户名的初始化

其他函数③——返回错误信息

chatroom聊天室—服务端（基于golang）相关推荐

最新文章

热门文章

golang，tcp服务——客户端源码下载