golang net包学习笔记

阅读源代码发现在net包中主要实现了ip、tcp、udp、unix等通信方式。它们大致可以分成两大类;其一,ip、udp、unix(DGRAM),这是一些无链接的协议,其二,tcp、unix(STREAM),需要建立链接。net对这两类协议的使用有一些区别,最明显的是对于tcp、unix(STEAM)这些协议需要使用一个Listener接口来进行服务端的监听,

其中每一种通信方式都使用 xxConn 结构体来表示,诸如IPConn、TCPConn等,这些结构体都实现了Conn接口,Conn接口实现了基本的读、写、关闭、获取远程和本地地址、设置timeout等功能。

 1 type Conn interface {
 2
 3     Read(b []byte) (n int, err error)
 4
 5     Write(b []byte) (n int, err error)
 6
 7     Close() error
 8
 9     LocalAddr() Addr
10
11     RemoteAddr() Addr
12
13     SetDeadline(t time.Time) error
14
15     SetReadDeadline(t time.Time) error
16
17     SetWriteDeadline(t time.Time) error
18 }

1、ip

使用IPConn结构体来表示,它实现了Conn、PacketConn两种接口。使用如下两个函数进行Dial和Listen。

 func DialIP(netProto string, laddr, raddr *IPAddr) (*IPConn, error)   

 func ListenIP(netProto string, laddr *IPAddr) (*IPConn, error)

2、tcp

使用TCPConn结构体来表示,它实现了Conn接口。

使用DialTCP进行Dial操作:

func DialTCP(net string, laddr, raddr *TCPAddr) (*TCPConn, error)

使用 ListenTCP函数进行Listen,产生一个TCPListener结构体

func ListenTCP(net string, laddr *TCPAddr) (*TCPListener, error)

使用TCPListener的AcceptTCP方法建立通信链路,得到TCPConn。

3、udp

使用UDPConn接口体来表示,它实现了Conn、PacketConn两种接口。使用如下两个函数进行Dial和Listen。

func DialUDP(net string, laddr, raddr *UDPAddr) (*UDPConn, error)    

func ListenUDP(net string, laddr *UDPAddr) (*UDPConn, error)

4、unix

UnixConn实现了Conn、PacketConn两种接口,其中unix又分为SOCK_DGRAM、SOCK_STREAM。

4.1 对于unix(SOCK_DGRAM),使用如下两个函数进行Dial和Listen。

func DialUnix(net string, laddr, raddr *UnixAddr) (*UnixConn, error)    

func ListenUnixgram(net string, laddr *UnixAddr) (*UnixConn, error)

4.2 对于unix(SOCK_STREAM)

客户端使用DialUnix进行Dial操作

func DialUnix(net string, laddr, raddr *UnixAddr) (*UnixConn, error)

服务端使用ListenUnix函数进行Listen操作,然后使用UnixListener进行AcceptUnix

func ListenUnix(net string, laddr *UnixAddr) (*UnixListener, error)

5 为了使用方便,golang将一些重复的操作集中到一个函数中。

可以发现上述几种通信,都得有Dialxxx、Listenxxx操作,但是根据有无链接,有分成了两大类,其中一种Listenxxx后直接返回对应的xxxConn,另一种Listenxxx后得到xxxListener,还需要借助Accepxxx进行获取xxxConn。所以为了偷懒,又有如下函数:

 func ListenPacket(net, laddr string) (PacketConn, error) 

这个函数用于侦听ip、udp、unix(DGRAM)等协议,返回一个PacketConn接口,同样根据侦听的协议不同,这个接口可以包含IPCon、UDPConn、UnixConn等,它们都实现了PacketConn。可以发现与ip、unix(stream)协议不同,直接返回的是xxConn,不是间接的通过Listener进行Accept操作后,才得到一个Conn。

 func Listen(net, laddr string) (Listener, error)

这个函数用于侦听tcp、unix(stream)等协议,返回一个Listener接口、根据侦听的协议不同,这个接口可以包含TCPListener、UnixListener等,它们都实现了Listener接口,然后通过调用其Accept方法可以得到Conn接口,进行通信。

 func Dial(network, address string) (Conn, error)

这个函数对于所有的协议都是相同的操作,返回一个Conn接口,根据协议的不同实际上包含IPConn、UDPConn、UnixConn、IPConn,它们都实现了Conn接口

时间: 2024-10-08 05:17:56

golang net包学习笔记的相关文章

Android V7包学习笔记更新中.....

关于V4 V7 V13 VX包介绍转自这里 1, Android Support V4, V7, V13是什么? 本质上就是三个java library. 2, 为什么要有support库? 如果在低版本Android平台上开发一个应用程序,而应用程序又想使用高版本才拥有的功能,就需要使用Support库. 3, 三个Support 库的区别和作用是什么? Android Support v4 是最早(2011年4月份)实现的库.用在Android1.6 (API lever 4)或者更高版本之

程序包(学习笔记)

示例一.根据输入的部门编号找到这个部门的所有员工 首先创建包,定义包规范 create or replace package getemp_pkg is FUNCTION getemp_fun(p_dno dept.deptno%type) RETURN SYS_REFCURSOR; --返回弱类型游标 end getemp_pkg; 执行后自动生成包的主体 定义包的主体(实现体) create or replace package body getemp_pkg AS FUNCTION get

如何打jar包 学习笔记

jar包是由.class文件压缩而成.要查看jar包中的内容,使用压缩工具 解压缩即可.也可以做修改,并重新打成jar包.总结一下最近学到的一些打jar包的方法: 一.DOS下使用jar命令 打jar包 (1)在DOS下输入命令:">jar",可以查看它的用法,如下图: (2)以下是一些常用例子,例子中所用文件目录结构如图: 示例1:将1.class和2.class打包到test.jar中,方法: 结果:jar-example下会新增test.jar,jar包目录结构如下: te

CoAP学习笔记——nodeJS node-coap返回JSON数据包

0 前言 本文说明如何使用node-coap返回JSON数据包.CoAP是专门为物联网系统开发的面向网络的应用层协议栈,CoAP建立在UDP协议之上尽可能减少网络开销,又具有HTTP Restful类型的特性.node-coap使用nodejs实现了coap的客户端和服务器端. [测试环境]--ubuntu/Linux [相关博文] [CoAP协议文档--The Constrained Application Protocol (CoAP)] [CoAP协议学习--CoAP基础] [CoAP学习

异常的学习笔记+打包+doc的包编译

jvm默认的异常处理机制就是调用printStackTrace方法 对于多异常的处理.应该是定义更具体的异常来捕捉捕捉问题 捕获异常代码块出现继承关系 应该把被继承的异常放在子类异常块的后面 throw 和 throws的区别 throw是是用在函数上,而throws是使用在函数内 throw后面跟的是异常对象,而throws跟的是异常类可以 多个 对异常的分类: 1.编译时被检测到的异常. (值得去处理的异常,或者是希望得到调用者处理,并不影响运算意向) 2.编译时不被检测到的异常(运行时异常

Java多线程之JUC包:ReentrantReadWriteLock源码学习笔记

若有不正之处请多多谅解,并欢迎批评指正. 请尊重作者劳动成果,转载请标明原文链接: http://www.cnblogs.com/go2sea/p/5634701.html ReentrantLock提供了标准的互斥操作,但在应用中,我们对一个资源的访问有两种方式:读和写,读操作一般不会影响数据的一致性问题.但如果我们使用ReentrantLock,则在需要在读操作的时候也独占锁,这会导致并发效率大大降低.JUC包提供了读写锁ReentrantReadWriteLock,使得读写锁分离,在上述情

Java多线程之JUC包:Semaphore源码学习笔记

若有不正之处请多多谅解,并欢迎批评指正. 请尊重作者劳动成果,转载请标明原文链接: http://www.cnblogs.com/go2sea/p/5625536.html Semaphore是JUC包提供的一个共享锁,一般称之为信号量. Semaphore通过自定义的同步器维护了一个或多个共享资源,线程通过调用acquire获取共享资源,通过调用release释放. 源代码: /* * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to lic

Hadoop源码学习笔记(2) ——进入main函数打印包信息

Hadoop源码学习笔记(2) ——进入main函数打印包信息 找到了main函数,也建立了快速启动的方法,然后我们就进去看一看. 进入NameNode和DataNode的主函数后,发现形式差不多: public static void main(String args[]) {     try {       StringUtils.startupShutdownMessage(DataNode.class, args, LOG);       DataNode datanode = crea

Wireshark学习笔记——如何快速抓取HTTP数据包

0.前言 在火狐浏览器和谷歌浏览器中可以非常方便的调试network(抓取HTTP数据包),但是在360系列浏览器(兼容模式或IE标准模式)中抓取HTTP数据包就不那么那么方便了.虽然也可使用HttpAnalyzer等工,但是毕竟都是收费软件.只需通过合适的过滤和操作,Wireshark也可抓取HTTP请求和响应.下面便说明具体操作. 假设在8080端口运行一个HTTP服务器,本例中使用Python Flask运行一个HTTP服务并侦听8080端口,实现一个简单的加法运算,网页中通过ajax提交