go语言编写,简单聊天室程序 1

eclipser1987 · · 1704 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

go语言网络编程,先从聊天室开始:

/**
 * Created by Vicky.H on 13-12-6.
 * eclipser@163.com
 */
package main

import (
	"fmt"
	"net"
	"strconv"
	"bytes"
	_ "bufio"
	_ "strings"
)

var m map[string]*net.Conn

func main() {

	m = make(map[string]*net.Conn, 10)

	listener ,err := net.Listen("tcp", ":8080")
	if err != nil {
		fmt.Errorf(err.Error())
		return
	}
	defer listener.Close()

	index := 0
	for {
		conn, err := listener.Accept()
		if err != nil {
			fmt.Errorf(err.Error())
			return
		}
		name := "用户:" + strconv.Itoa(index)
		defer connCloseHandler(name, conn)
		m[name] = &conn
		index++
		go connHandler(name, conn)
	}
}

func connCloseHandler(name string, conn net.Conn) {
	conn.Close()
	delete(m, name)
	for key := range(m)  {
		if key != name {
			(*(m[key])).Write(bytes.NewBufferString(name + " 离开房间\n").Bytes())
			(*(m[key])).Write(bytes.NewBufferString("当前房间人数:" + strconv.Itoa(len(m)) + "\n").Bytes())
		}
	}
}


func connHandler (name string, conn net.Conn) {
	conn.Write(bytes.NewBufferString("当前房间人数:" + strconv.Itoa(len(m)) + "\n").Bytes())
	for key := range(m)  {
		if key != name {
			(*(m[key])).Write(bytes.NewBufferString(name + " 进入房间\n").Bytes())
		}
	}
	for {
		buf := make([]byte,1024)
		conn.Read(buf)
		msg := string(buf)
		conn.Write(bytes.NewBufferString("我说: " + msg).Bytes())
		for key := range(m)  {
			if key != name {
				(*(m[key])).Write(bytes.NewBufferString(name + " 说: " + msg).Bytes())
			}
		}
	}
}


运行:go run main.go


测试结果






有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:eclipser1987

查看原文:go语言编写,简单聊天室程序 1

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

1704 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传