使用Golang怎么實(shí)現(xiàn)并發(fā)聊天室？針對(duì)這個(gè)問(wèn)題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。

在湘鄉(xiāng)等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專(zhuān)注、極致的服務(wù)理念，為客戶(hù)提供做網(wǎng)站、成都網(wǎng)站制作 網(wǎng)站設(shè)計(jì)制作按需定制開(kāi)發(fā),公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站制作,營(yíng)銷(xiāo)型網(wǎng)站建設(shè),外貿(mào)網(wǎng)站建設(shè),湘鄉(xiāng)網(wǎng)站建設(shè)費(fèi)用合理。

package main
import (
  "net"
  "fmt"
  "strings"
  "time"
)
//定義的此結(jié)構(gòu)體為全局map的value值，包括每一個(gè)用戶(hù)的姓名，ip地址和私人管道
type client struct {
  name string
  addr string
  C  chan string
}
/*這個(gè)函數(shù)是將私人管道中的內(nèi)容發(fā)送給用戶(hù)，配合全局管道Message使用可以實(shí)現(xiàn)廣播的功能，
單獨(dú)使用可以實(shí)現(xiàn)私聊的功能*/
func writemsg2client(clinet client,conn net.Conn) {
  for m := range clinet.C {
    conn.Write([]byte(m + "\n"))
  }
}
//這只是一個(gè)封裝好用來(lái)統(tǒng)一(發(fā)送信息格式)的小函數(shù)，不用在意
func makemsg(name string, addr string, s string) string {
  return "[" + addr + "]" + name + s
}
//每一個(gè)進(jìn)入聊天室的用戶(hù)都將啟動(dòng)一個(gè)handleconn的go程來(lái)處理事件
func handleconn(conn net.Conn) {
  defer conn.Close()
/*用戶(hù)連接進(jìn)來(lái)以后要初始化全局map，把自己的信息加入到字典里，相當(dāng)于進(jìn)到聊天室里之前要登
記一下個(gè)人信息，注意姓名初始為ip地址。*/
  addr := conn.RemoteAddr().String()
  fmt.Printf("用戶(hù)%s進(jìn)入了房間\n", addr)
  client := client{addr, addr, make(chan string)}
  //在這里啟動(dòng)子go程，功能上面已經(jīng)提及
  go writemsg2client(client,conn)
  onlinemap[addr] = client
  //登錄進(jìn)來(lái)一切準(zhǔn)備就緒后就給所有人廣播上線信息啦
  Message <- makemsg(client.name, addr, "login")
  //下面這三個(gè)變量服務(wù)于下面一些小功能
  var haschat=make(chan bool)
  var ifquit=make(chan bool)
  var flag bool
  //從這單獨(dú)開(kāi)啟一個(gè)go程來(lái)讀取用戶(hù)輸入的信息
  go func() {
    buf:=make([]byte,4096)
    for {
      n,_:=conn.Read(buf)
      if n==0 {
        fmt.Printf("%s離開(kāi)了房間\n",client.name)
        ifquit<-true
        return
      }
      //改名功能的實(shí)現(xiàn)
      if string(buf[:7])=="Rename|" {
        client.name=strings.Split(string(buf[:n-1]),"|")[1]
        onlinemap[addr]=client
        conn.Write([]byte("rename success\n"))
      }else if string(buf[:n-1])=="/who"{
      //查詢(xún)?cè)诰€用戶(hù)信息的功能
        for _,s:=range onlinemap{
          conn.Write([]byte(s.name+"online\n"))
        }
      }else if string(buf[:2])=="m|"&&strings.Count(string(buf[:n]),"|")==2 {
/*私聊功能的實(shí)現(xiàn)，其實(shí)私聊功能就是跳過(guò)了往全局Message里傳輸信息，
改為直接向私人管道里傳輸信息*/
        flag=false
        slice:=strings.Split(string(buf[:n-1]),"|")
        for _,a:=range onlinemap{
        //遍歷所有在線用戶(hù)，向指定的用戶(hù)管道中發(fā)送信息
          if a.name==slice[1]{
            flag=true
            a.C<-makemsg(client.name,addr,slice[2])
            conn.Write([]byte("send success"))
          }
        }
        if flag {
          conn.Write([]byte("no such man or not online"))
        }
      } else {
        Message<-makemsg(client.name,addr,string(buf[:n-1]))
      }
      haschat<-true
    }
  }()
  for {
    select {
    case <-haschat:
    //超時(shí)強(qiáng)踢
    case <-time.After(time.Minute*3):
      delete(onlinemap,addr)
      Message<-makemsg(client.name,addr,"out time to leave")
      close(client.C)
      return
    case <-ifquit:
    //退出處理
      delete(onlinemap,addr)
      Message<-makemsg(client.name,addr,"out time to leave")
      close(client.C)
      return
    }
  }
}
//這個(gè)函數(shù)用來(lái)將全局Message中的內(nèi)容全部塞到私人管道C里，實(shí)現(xiàn)上下線廣播和群聊的功能
func Manager() {
  for {
    msg := <-Message
    for _, s := range onlinemap {
      s.C <- msg
    }
  }
}
var Message = make(chan string)
var onlinemap map[string]client = make(map[string]client)
//主函數(shù)
func main() {
  listener, _ := net.Listen("tcp", "127.0.0.1:6666")
  defer listener.Close()
  //提前開(kāi)啟全局Message的go程，防止被阻塞
  go Manager()
  for {
    conn, err := listener.Accept()
    if err != nil {
      fmt.Println("accept err", err)
      continue
    }
    //每一個(gè)連接進(jìn)來(lái)的用戶(hù)都會(huì)被分配進(jìn)入一個(gè)子go程，用來(lái)處理上面我們提到的各種功能
    go handleconn(conn)
  }
}

關(guān)于使用Golang怎么實(shí)現(xiàn)并發(fā)聊天室問(wèn)題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒(méi)有解開(kāi)，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。

名稱(chēng)欄目：使用Golang怎么實(shí)現(xiàn)并發(fā)聊天室
URL網(wǎng)址：http://www.chinadenli.net/article46/pesieg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供手機(jī)網(wǎng)站建設(shè)、關(guān)鍵詞優(yōu)化、搜索引擎優(yōu)化、網(wǎng)頁(yè)設(shè)計(jì)公司、軟件開(kāi)發(fā)、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)