专栏首页Golang语言社区Golang实现的私聊服务

Golang实现的私聊服务

2860元腾讯云代金券免费领取,付款直接抵现金,立即领取>>>

腾讯云海外服务器1折限时抢购,2核4G云主机689元/1年,立即抢购>>>

腾讯云服务器1折限时抢购,2核4G云主机689元/3年,立即抢购>>>

一个简单的golang实现的私聊,由服务器端决定两两匹配 服务器端 chat_server.go

package main


import (
    "fmt"
    "io"
    "log"
    "net"
)


const listenAddr = "localhost:4000"

func main() {
    l, err := net.Listen("tcp", listenAddr)
    if err != nil {
        log.Fatal(err)
    }
    for {
        c, err := l.Accept()
        if err != nil {
        log.Fatal(err)
    }
    //go io.Copy(c, c)
    go match(c)
    }
}


var partner = make(chan io.ReadWriteCloser)


func match(c io.ReadWriteCloser) {
    fmt.Fprint(c, "Waiting for a partner...")
    select {
    case partner <- c:
        // now handled by the other goroutine
    case p := <-partner:
    chat(p, c)
    }
}


/*
func chat(a, b io.ReadWriteCloser) {
    fmt.Fprintln(a, "Found one! Say hi.")
    fmt.Fprintln(b, "Found one! Say hi.")
    go io.Copy(a, b)
    io.Copy(b, a)
}
*/


func chat(a, b io.ReadWriteCloser) {
    fmt.Fprintln(a, "Found one! Say hi.")
    fmt.Fprintln(b, "Found one! Say hi.")
    errc := make(chan error, 1)
    go cp(a, b, errc)
    go cp(b, a, errc)
    if err := <-errc; err != nil {
        log.Println(err)
    }
    a.Close()
    b.Close()
}

func cp(w io.Writer, r io.Reader, errc chan<- error)        {
    _, err := io.Copy(w, r)
    errc <- err
}

客户端chat_client.go:

package main
import (
    "fmt"
    "log"
    "net"
)

func main() {
    l, err := net.Dial("tcp", "localhost:4000")
    if err != nil {
        log.Fatal(err)
    }
    go send(l)
    for {
        datas := make([]byte, 255)
        n, err := l.Read(datas)
        if err != nil {
            log.Fatal(err)
        }
    fmt.Println(string(datas[0:n]))
    }   
}


func send(l net.Conn){
    sms := make([]byte, 255)
    for{
        //fmt.Print("请输入要发送的消息:")
        _, err := fmt.Scan(&sms)
        if err != nil {
            fmt.Println("数据输入异常:", err.Error())
        }

        l.Write(sms)
    }
}

本文分享自微信公众号 - Golang语言社区(Golangweb)

原文出处及转载信息见文内详细说明,如有侵权,请联系 [email protected] 删除。

原始发表时间:2016-03-11

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 【OpenIM原创】AppServer、AppClient、Open-IM-Server以及Open-IM-SDK之间的关系

    Open-IM是由前微信技术专家打造的开源的即时通讯组件。Open-IM包括IM服务端和客户端SDK,实现了高性能、轻量级、易扩展等重要特性。开发者通过集成Op...

    用户8964349
  • Golang学习--tcp服务实现

    golang实现tcp编程主要用到net包下面的几个方法: net.Listen:监听一个地址 Listener接口中的Accept:接收一个请求连接 n...

    anakinsun
  • Golang实现图片缩放服务器

    package main import ( "fmt" "graphics" "image" "image/png" "...

    李海彬
  • Golang实现web文件共享服务

    http.Handle("/", http.FileServer(http.Dir("./"))) //把当前文件目录作为共享目录

    猿哥
  • Golang之chan/goroutine

    最近在team内部培训golang,目标是看看golang能否被C工程师快速掌握。我定了个一个月,共计20小时的培训计划,首先花10个小时(两周,每天1小时)让...

    李海彬
  • 基于websocket单台机器支持百万连接分布式聊天(IM)系统

    使用golang实现websocket通讯,单机可以支持百万连接,使用gin框架、nginx负载、可以水平部署、程序内部相互通讯、使用grpc通讯协议。

    link1st
  • 在 Node.js 中引入 Golang ,会让它更快吗?

    大家好,我是 ConardLi,今天我们来看个有意思的话题,在 Node.js 中引入 Golang ,会让服务更快吗?

    ConardLi
  • 天池中间件大赛Golang版Service Mesh思路分享(作者:我的 96 年表弟)

    这次天池中间件性能大赛初赛和复赛的成绩都正好是第五名,出乎意料的是作为Golang是这次比赛的“稀缺物种”,这次在前十名中我也是侥幸存活在C大佬和Java大佬的...

    芋道源码
  • Golang微服务实践

    在之前的文章《漫谈微服务》我已经简单的介绍过微服务,微服务特性是轻量级跨平台和跨语言的服务,也列举了比较了集中微服务通信的手段的利弊,本文将通过RPC通信的方式...

    用户2937493
  • 聊一聊微服务架构中的服务发现系统

    导语:本文围绕服服务调用模式、一致性取舍、服务提供者的健康检查模式等方面,讨论了服务发现的技术选型和设计的各种优缺点,希望能够帮助大家在选择或者使用服务发现系统...

    腾讯云中间件团队
  • 天池中间件大赛Golang版Service Mesh思路分享

    这次天池中间件性能大赛初赛和复赛的成绩都正好是第五名,出乎意料的是作为Golang是这次比赛的“稀缺物种”,这次在前十名中我也是侥幸存活在C大佬和Java大佬的...

    涤生
  • Go和HTTPS -2

    F为签名函数。CA自己的私钥是唯一标识CA签名的,因此CA用于生成数字证书的签名函数一定要以自己的私钥作为一个输入参数。在RSA加密 系统中,发送端的解密函数就...

    李海彬
  • 由浅入深聊聊Golang中select的实现机制

    select是go语言中常用的一个关键字,其用法也一直被用作面试题来考核应聘者。今天,结合代码来分析下select的主要用法。

    会呼吸的Coder
  • [Golang软件推荐] RSA公私钥加解密(解决Golang私钥加密公钥解密问题)

    安全是软件开始中很重要的一个环节,在金融场景以及设计资产的场景下更是如此,在加密算法中主要使用较多加密方式分别是对称加密和非对称加密,对称加密中的代表是AES,...

    喵了个咪233
  • Skywalking Tracing 的接入和使用 —— Trace 之 OpenTelemetry 系列第三弹

    导读 然后我们就进入标准的实操阶段,市面上有3个非常受欢迎的包含tracing的项目,skywalking,zipkin和jaeger。这篇文章希望通过解释sk...

    腾讯云中间件团队
  • 为什么GOPROXY对Golang开发如此重要

    从Go 1.13开始,Go Module作为Golang中的标准包管理器,在安装时自动启用,并附带一个默认的GOPROXY。

    JFrog杰蛙科技
  • go go go - beego

    在上一篇文章What!!! so fast中,我介绍了golang这种语言,并使用golang开发了一个端口扫描工具。现在我的主要工作是做网络安全方面的开发与策...

    七夜安全博客
  • Go和HTTPS--1

    近期在构思一个产品,考虑到安全性的原因,可能需要使用到HTTPS协议以及双向数字证书校验。之前只是粗浅接触过HTTP(使用Golang开 发微信系列)。对HTT...

    李海彬
  • 【OpenIM原创】C/C++调用golang函数,golang回调C/C++函数

    Open-IM 是由前微信技术专家打造的全开源、永久免费、无限制的即时通讯组件。Open-IM 包括 IM 服务端和客户端 SDK,实现了高性能、轻量级、易扩展...

    用户8964349

扫码关注云+社区

领取腾讯云代金券

http://www.vxiaotou.com