Golang简单聊天系统开发项目-Golang-PHP中文网

Golang简单聊天系统开发项目

P粉602998670

发布： 2025-09-28 16:23:01

原创

777人浏览过

先实现TCP聊天服务器与客户端，通过goroutine处理并发连接，使用channel广播消息。服务器管理用户登录、消息转发和断开，客户端支持输入输出交互，可扩展私聊、历史记录等功能。

golang简单聊天系统开发项目

开发一个简单的聊天系统是学习Golang网络编程和并发处理的绝佳方式。通过这个项目，你可以掌握TCP通信、goroutine、channel等核心特性。下面是一个基础但完整的Golang简单聊天系统的实现思路与代码结构。

1. 项目目标

实现一个基于命令行的多人聊天系统，支持以下功能：

多个客户端可以连接到服务器
任意客户端发送的消息能广播给所有其他在线客户端
服务器能实时管理连接和断开的用户
支持用户名登录（可选）

2. 技术架构

采用C/S（客户端-服务器）模型，使用TCP协议进行通信。

服务器端：监听端口，接受多个客户端连接，使用goroutine处理每个连接，通过channel广播消息
客户端：连接服务器，发送和接收消息，支持本地输入输出

3. 服务器端实现

服务器主要职责是管理连接池、读取客户端消息并广播给其他人。

立即学习“go语言免费学习笔记（深入）”；

package main
<p>import (
"bufio"
"fmt"
"log"
"net"
)</p><p>type Client struct {
conn net.Conn
name string
}</p><p>var (
clients   = make(map[net.Conn]<em>Client)
broadcast = make(chan string)
enter     = make(chan </em>Client)
leave     = make(chan *Client)
)</p><p>func broadcaster() {
for {
select {
case msg := <-broadcast:
for conn := range clients {
<em>, err := fmt.Fprintln(conn, msg)
if err != nil {
log.Printf("广播错误: %v", err)
leave <- clients[conn]
}
}
case client := <-enter:
clients[client.conn] = client
broadcast <- fmt.Sprintf("[系统] %s 加入聊天", client.name)
case client := <-leave:
if </em>, ok := clients[client.conn]; ok {
close(client.conn)
delete(clients, client.conn)
broadcast <- fmt.Sprintf("[系统] %s 离开聊天", client.name)
}
}
}
}</p><p>func handleConn(conn net.Conn) {
defer func() {
if r := recover(); r != nil {
log.Printf("连接处理异常: %v", r)
}
}()</p><pre class='brush:php;toolbar:false;'>fmt.Fprint(conn, "请输入你的用户名: ")
reader := bufio.NewReader(conn)
name, _ := reader.ReadString('\n')
name = name[:len(name)-1] // 去除换行符

client := &Client{conn: conn, name: name}
enter <- client

go func() {
    for {
        msg, err := reader.ReadString('\n')
        if err != nil {
            leave <- client
            break
        }
        broadcast <- fmt.Sprintf("%s: %s", name, msg)
    }
}()

// 阻塞等待退出信号
select {}

登录后复制

}

飞蛙B2C微分销商城系统

飞蛙微分销商城系统（FeiWa WeiShop）是一款面向单店铺多用户微商城分销系统，基于目前最流行的WEB2.0的架构，使用php+mysql开发框架，系统全面导入整合最流行的三级分销机制。开发团队拥有成熟、稳定的微电商技术解决方案，是为了快速简化企业微商城应用开发、帮助微商企业快速赚钱而诞生的。

查看详情

func main() { listener, err := net.Listen("tcp", ":8080") if err != nil { log.Fatal(err) } defer listener.Close()

go broadcaster()

fmt.Println("聊天服务器启动在 :8080...")
for {
    conn, err := listener.Accept()
    if err != nil {
        log.Print(err)
        continue
    }
    go handleConn(conn)
}

登录后复制

}

4. 客户端实现

客户端负责连接服务器，发送用户输入，并持续接收服务器转发的消息。

package main
<p>import (
"bufio"
"fmt"
"log"
"net"
"os"
)</p><p>func main() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal(err)
}
defer conn.Close()</p><pre class='brush:php;toolbar:false;'>go func() {
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        fmt.Println(scanner.Text())
    }
}()

// 从标准输入读取并发送
input := bufio.NewScanner(os.Stdin)
for input.Scan() {
    text := input.Text() + "\n"
    _, err := conn.Write([]byte(text))
    if err != nil {
        log.Printf("发送失败: %v", err)
        break
    }
}

登录后复制

}