golang中net的tcp服务使用

目录
  • 服务端监听端口 listen()
    • 接受客户端的链接conn.Accept()
    • 接收客户端发过来的数据newConn.Read()
    • 获取客户端的IP地址newConn.RemoteAddr().String()
    • 向客户端发送数据newConn.Write()
    • 关闭客户端连接newConn.Close()
  • 客户端连接tpc服务端
    • 连接服务端net.Dial()

服务端监听端口 listen()

方法：net.listen({监听类型},{监听的ip和端口})(conn, err){}

返回值：conn是监听的对象，有获取消息关闭监听等方法err错误信息，如果没有错误信息值为nil

import ("net"
"fmt"
)
conn,err := net.Lisien("tcp","127.0.0.1:8082")
if err != nil{
  fmt.Println("链接失败，错误信息为："+err)
}

接受客户端的链接conn.Accept()

方法：conn.Accept() (newConn,err){} 返回值： newConn客户端的链接对象，类型为net.Conn.存放了客户端的链接信息，和与客户端交互的方法.err存放错误，如果没有错误信息值为nil 注意点： Accept()方法会阻塞，直到有链接过来

//  ...上面的代码...
// 因为客户端的链接不止一个，需要一直监听，所以加个死循环
for{
    newConn,err := conn.Accept()
    if err != nil{
        fmt.Println(err)
    }
    go handler(newConn)
}
​
// 客户端连接后处理逻辑
func handler(newConn net.Conn){
    // TODO
}

接收客户端发过来的数据newConn.Read()

方法：newConn.Read(msg)(num,err){}

返回值： num数据内容的长度，单位字节err错误信息，如果没有错误信息值为nil

注意点： 参数msg是一个byte类型的切片，用来保存客户端发送的数据。Read方法同样会阻塞！！

// ...上上边代码补充...
// 客户端连接后处理逻辑
func handler(newConn net.Conn){
    for{
        // 新建一个位置用于存放客户端数据
        msg := make([]byte,1024)
        num,err := newConn.Read(msg)
        if err != nil{
            // 打印错误信息
        }
        fmt.Println("客户端消息："+msg)
    }
    
}

获取客户端的IP地址newConn.RemoteAddr().String()

// 获取ip地址，转为之字符串
newConn.RemoteAddr().String()

向客户端发送数据newConn.Write()

方法：newConn.Write(msg){}

参数：msg类型为[]byte。

注意点：需要把待发送的字符串转为byte切片类型

newConn.Write([]bye("你好世界，helloworld1"))

关闭客户端连接newConn.Close()

方法： newConn.Close(){}

在客户端连接的返回的对象上调用Close()方法即可

newConn.Close()

客户端连接tpc服务端

连接服务端net.Dial()

方法： net.Dial({连接类型},{地址})(conn,err){}

放回值： conn连接成功后的连接对象，err连接出错时的错误信息，如果没有错误信息，返回nil

// 建立tcp连接
package main
import (
    "net"
    "fmt"
)
Ip,Port := "127.0.0.1",8081
conn,err := net.Dial("tcp",fmt.Sprintf("%s:%d",Ip,Port))
if err != nil{
    fmt.Println("net.Dial 错误：",err)
    return nil
}
if(conn == nil){
    fmt.Println(">>>>>>>>连接错误")
    return
}
fmt.Println(">>>>>>>>连接成功")

运行： 

到此这篇关于golang中net的tcp服务使用的文章就介绍到这了,更多相关net的tcp服务使用内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • 在Go中构建并发TCP服务器

    在Go中构建并发TCP服务器

    开发一个并发TCP服务器,该服务器仅使用大约65行GO代码生成随机数. TCP和UDP服务器随处可见,通过TCP/IP网络为网络客户端提供服务.在本文中,我将在GO编程语言,返回随机数.对于来自TCP客户端的每个传入连接,TCP服务器将启动一个新的goroutine来处理该请求. 你可以找到这个项目,concTCP.go,在GitHub上. 处理TCP连接 程序的逻辑可以在handleConnection()职能,其实现方式如下: func handleConnection(c net.Conn

  • Golang 实现Socket服务端和客户端使用TCP协议通讯

    Socket服务器是网络服务中常用的服务器.使用go语言实现这个业务场景是很容易的. 这样的网络通讯,需要一个服务端和至少一个客户端. 我们计划构建一个这样的通讯工程.服务端启动后等待客户端的访问.客户端发送一段信息给服务端.服务端接收到信息后,再回馈给客户端一段信息. 首先要建立服务端.服务端最先要做的事情就是"建立Socket端口监听". netListen, err := net.Listen("tcp", "localhost:1024"

  • GO语言实现简单TCP服务的方法

    本文实例讲述了GO语言实现简单TCP服务的方法.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: package main import ( "net" "fmt" ) var (   maxRead = 1100     msgStop   = []byte("cmdStop")     msgStart  = []byte("cmdContinue")     ) func main() {       ho

  • Go语言服务器开发之简易TCP客户端与服务端实现方法

    本文实例讲述了Go语言服务器开发之简易TCP客户端与服务端实现方法.分享给大家供大家参考.具体实现方法如下: Go语言具备强大的服务器开发支持,这里示范了最基础的服务器开发:通过TCP协议实现客户端与服务器的通讯. 一 服务端,为每个客户端新开一个goroutine 复制代码 代码如下: func ServerBase() {      fmt.Println("Starting the server...")      //create listener      listener,

  • golang中net的tcp服务使用

    golang中net的tcp服务使用

    目录 服务端监听端口 listen() 接受客户端的链接conn.Accept() 接收客户端发过来的数据newConn.Read() 获取客户端的IP地址newConn.RemoteAddr().String() 向客户端发送数据newConn.Write() 关闭客户端连接newConn.Close() 客户端连接tpc服务端 连接服务端net.Dial() 服务端监听端口 listen() 方法:net.listen({监听类型},{监听的ip和端口})(conn, err){} 返回值:

  • Golang中基于HTTP协议的网络服务

    目录 一.HTTP协议的网络服务 1.1 使用http.Get函数访问HTTP协议的网络服务 1.2 使用缺省客户端DefaultClient(类型为*http.Client ) 1.3 使用http.Client访问HTTP协议的网络服务 二.http.Client中的Transport字段 (1)http.Transport类型中的DialContext字段 (2)http.Transport类型中的其它字段 三.为什么会出现空闲的连接 3.1 空闲连接的产生 3.2 杜绝空闲连接的产生 四

  • 在Golang中使用Redis的方法示例

    周五上班的主要任务是在公司老平台上用redis处理一个队列问题,顺便复习了一下redis操作的基础知识,回来后就想着在自己的博客demo里,用redis来优化一些使用场景,学习一下golang开发下redis的使用. Redis简单介绍 简介 关于Redis的讨论,其实在现在的后台开发中已经是个老生常谈的问题,基本上也是后端开发面试的基本考察点.其中 Redis的背景介绍和细节说明在这里就不赘述.不管怎么介绍,核心在于Redis是一个基于内存的key-value的多数据结构存储,并可以提供持久化

  • 在Golang中使用http.FileServer返回静态文件的操作

    在Golang中使用http.FileServer返回静态文件的操作

    Golang中使用http.FileServer 使用http.FileServer可以管理向浏览器返回静态文件 http.Handle("/",http.FileServer(http.Dir("/Users/administrator/Desktop/public"))) err := http.ListenAndServe("0.0.0.0:8080",nil) if err!=nil{ fmt.Print(err); } 补充:golan

  • golang基于websocket通信tcp keepalive研究记录

    golang基于websocket通信tcp keepalive研究记录

    目录 为什么有tcp Keepalive? tcp Keepalive是否默认开启? 如何设置tcp keepalive? 在Linux内核设置 golang websocket 客户端默认怎么处理tcp keepalive? golang websocket 服务器默认怎么处理tcp keepalive? 为什么有tcp Keepalive? 服务器和客户端建立tcp连接以后,客户端/服务器如何知道对方是否挂掉了? 这时候TCP协议提出一个办法,当客户端端等待超过一定时间后自动给服务端发送一个

  • 一文详解Golang中net/http包的实现原理

    一文详解Golang中net/http包的实现原理

    目录 前言 http包执行流程 http包源码分析 端口监听 请求解析 路由分配 响应处理 前言 Go语言自带的net/http包提供了HTTP客户端和服务端的实现,实现一个简单的http服务非常容易,其自带了一些列结构和方法来帮助开发者简化HTTP服务开发的相关流程,因此我们不需要依赖任何第三方组件就能构建并启动一个高并发的HTTP服务器,net/http包在编写web应用中有很重要的作用,这篇文章会学习如何用 net/http 自己编写实现一个 HTTP Server 并探究其实现原理,具体

  • golang实现简单的tcp数据传输

    目录 前言 首先介绍什么是Tcp协议 什么是可靠数据传输? TCP的快速重传机制 简单介绍TCP连接的三次握手和四次挥手 三次握手 四次挥手 golang实现简单的tcp连接建立 服务端 完整代码 客户端 完整代码 前言 通过golang实现Tcp的连接与信息传输 本文主要介绍Tcp协议以及如何使用golang来建立一个简单的tcp连接服务,并且实现信息的传输. 首先介绍什么是Tcp协议 Tcp协议是传输层的一个可靠数据传输协议,Tcp协议有以下几个特点: 点对点的发送:一个发送方,一个接收方

  • 一文详解Golang中consul的基本使用

    目录 consul consul的安装和部署 docker安装 consul镜像的启动 启动一个tcp_health_check的服务注册 http版 服务发现 consul consul是一个开源服务注册和服务发现的中心,可以用于微服务的注册和服务之间的调用的发现,帮助上游服务找到下游服务的具体ip:port或者是domain,也可以使用dns的方式让consul帮你去做转发,具体介绍请看consul的官网,consul区分server-agent和client-agent,client-ag

  • Golang中switch语句和select语句的用法教程

    本文主要给大家介绍了关于Golang中switch和select用法的相关内容,分享出来供大家参考学习,下面来一起看看详细的介绍: 一.switch语句 switch语句提供了一个多分支条件执行的方法.每一个case可以携带一个表达式或一个类型说明符.前者又可被简称为case表达式.因此,Go语言的switch语句又分为表达式switch语句和类型switch语句. 1.表达式switch语句 var name string ... switch name { case "Golang"

  • Java Socket编程实例（三）- TCP服务端线程池

    一.服务端回传服务类: import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; public class EchoProtocol implements Runnable { private static f

随机推荐