【Linux编程】socket编程

套接字是通信端点的抽象。文件描写叙述符用open函数创建，而套接字描写叙述符用socket函数创建。socket函数原型例如以下：

int socket(int domain, int type, int protocol);
// 返回值：成功返回套接字描写叙述符，失败返回-1

domain域确定通信特性。不同的域表示地址的格式不同，表示域的常数以AF开头。表示地址族（address family）：

watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvbmVzdGxlcg==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast" >

type确定套接字类型。进一步确定通信特征：

protocol通常为0，表示按上述两个參数确定默认的协议。比如：

  • 通信域为AF_INET。套接字类型为SOCK_STREAM。则默认协议为TCP。
  • 通信域为AF_INET。套接字类型为SOCK_DGRAM。则默认协议为UDP。

关闭套接字的一端可用shutdown函数：

int shutdown(int sockfd, int how);
// 返回值：成功返回0，失败返回-1

how为SHUT_RD，关闭读端，无法从套接字读取数据；how为SHUT_WR。关闭写端，无法通过套接字发送数据。

关闭套接字描写叙述符的方法和关闭文件描写叙述符的方法同样，都是使用close函数。

不同的CPU。使用不同的字节序列来表示数据，分大端序和小端序。比如大端序的机器发送到小端序的机器上，则接收到的数据顺序会颠倒。为了避免这样的情况，使网络传输与详细的机器类型无关，採用网络字节序。发送方把本机序转换为网络字节序后发送，接收方把接收到的网络字节序转换为本机序。

TCP/IP採用大端字节序，即网络字节序，而我们经常使用的X86结构是小端模式。下图来自维基百科，描写叙述得非常形象：

 
  

TCP/IP应用程序提供了四个通用函数用于本地字节序和网络字节序之间的转换：

  1. htonl：本地32位整型转网络字节序
  2. htons：本地16位整型转网络字节序
  3. ntohl：网络字节序转32位整型本地字节序
  4. ntohs：网络字节序转16位整型本地字节序

下面是TCP和UDP程序的相关函数接口的调用过程。

1、TCP服务端：

  • socket：建立一个传输端点。返回一个套接字描写叙述符。

  • bind：将套接字绑定到某个IP和port。此IP和port就作为监听对象。注意，因为系统会分配给client默认地址。所以client使用该函数意义不大。

  • listen：将套接字转换成监听套接字，使得client的连接请求可被内核接受，上述三步为设置监听描写叙述符的正常步骤。
  • accept：休眠。等待客户连接被内核接受。三次握手完成后返回一个新的套接字描写叙述符。该描写叙述符连接到调用connect的client。被称为已连接描写叙述符。
  • send：发数据。
  • recv：收数据。
  • close：关闭连接，引发四次握手。

2、TCPclient：

  • socket：创建套接字。
  • connect：建立连接。指明目的，和服务端的accept函数相应。

  • send：发数据。
  • recv：收数据。

3、UDP服务端：

  • socket：建立套接字。
  • bind：绑定监听的IP和port。
  • recvfrom：堵塞等待数据的到来。

4、UDPclient：

和TCPclient基本一致。假设在发送之前使用了connect函数。那么发送报文的目的地址都是connect调用中所指定的地址。所以直接send函数进行发送。

没用之前没有调用connect函数，发送用sendto函数。这个函数须要在參数中指定目的地址。

下面是一些例程。

TCPclient：

/* 基于TCP协议的socket编程client代码 */

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

/* client:
 * socket-->connect-->send/recv
 */

#define SERVER_PORT 8888

int main(int argc, char **argv)
{
    int iRet;
    int iSocketClient;
    struct sockaddr_in tSocketServerAddr;

    int iSendLen;
    unsigned char ucSendBuf[1000];

    if (argc != 2)
    {
        printf("Usage:\n");
        printf("%s <server_ip>\n", argv[0]);
        return -1;
    }

    /* 1. 建立socket */
    iSocketClient = socket(AF_INET, SOCK_STREAM, 0);

    /* 2. 与服务器建立TCP连接 */
    tSocketServerAddr.sin_family = AF_INET;            /* recommend */
    tSocketServerAddr.sin_port   = htons(SERVER_PORT); /* host to net short */
    if (inet_aton(argv[1], &tSocketServerAddr.sin_addr) == 0) /* 字符串转服务器IP */
    {
        printf("Invalid server IP\n");
        return -1;
    }
    bzero(tSocketServerAddr.sin_zero, 8);

    /* 假设iSocketClient没有绑定地址。则connect会给调用者绑定一个默认地址 */
    iRet = connect(iSocketClient, (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
    if (iRet == -1)
    {
        /* 连接失败 */
        printf("connect error\n");
        return -1;
    }

    while (1)
    {
        if (fgets(ucSendBuf, 999, stdin))
        {
            /* send函数发送数据 */
            iSendLen = send(iSocketClient, ucSendBuf, strlen(ucSendBuf), 0);
            if (iSendLen == -1)
            {
                /* 函数出错 */
                close(iSocketClient);
                return -1;
            }
        }
    }

    return 0;
}

TCP服务端：

/* 基于TCP协议的socket编程server端代码 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
/* server:
 * socket-->bind-->listen-->accept-->send/recv
 */
#define SERVER_PORT 8888
#define BACKLOG     10
int main(int argc, char **argv)
{
    int iRet;
    int iAddrLen;
    int iSocketSever;
    int iNewSocketSever;
    struct sockaddr_in tSocketServerAddr;
    struct sockaddr_in tSocketClientAddr;
    int iRecvLen;
    unsigned char ucRecvBuf[1000];
    /* 子进程死后，会发送SIGCHLD信号给父进程，
     * 这里设置为忽略SIGCHLD信号
     */
    signal(SIGCHLD,SIG_IGN);
    /* 1. 建立socket
     * AF_INET: IPv4 Internet protocols
     * SOCK_STREAM: TCP协议
     * 0: 通常赋值
     */
    iSocketSever = socket(AF_INET, SOCK_STREAM, 0);
    if (iSocketSever == -1)
    {
        printf("socket error\n");
        return -1;
    }
    /* 2. 配置socket
     * 设置监听本机的哪个IP，端口
     */
    tSocketServerAddr.sin_family      = AF_INET;            /* recommend */
    tSocketServerAddr.sin_port        = htons(SERVER_PORT); /* host to net short */
    tSocketServerAddr.sin_addr.s_addr = htonl(INADDR_ANY);  /* 绑定到本机全部网络接口 */
    bzero(tSocketServerAddr.sin_zero, 8);
    iRet = bind(iSocketSever, (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
    if (iRet == -1)
    {
        printf("bind error\n");
        return -1;
    }
    /* 3. 开启socket监听模式
     * 建立服务请求队列，BACKLOG为最大连接数
     */
    iRet = listen(iSocketSever, BACKLOG);
    if (iRet == -1)
    {
        printf("listen error\n");
        return -1;
    }
    while (1)
    {
        /* 4. 休眠，等待建立连接
         * client地址存放在第二个參数中
         * 以后用新的socket描写叙述符进行读写操作
         */
        iAddrLen = sizeof(struct sockaddr);
        iNewSocketSever = accept(iSocketSever, (struct sockaddr *)&tSocketClientAddr, &iAddrLen);
        if (iNewSocketSever != -1)
        {
            /* 成功建立连接 */
            printf("Get connect from IP:%s, port:%d\n", inet_ntoa(tSocketClientAddr.sin_addr), ntohs(tSocketClientAddr.sin_port));    /* net to ascII */
            /* fork系统调用创建子进程 */
            if (fork() == 0)
            {
                /* 子进程源代码 */
                while (1)
                {
                    /* recv函数接收client数据并显示，假设flags为0，则和read、write一样的操作 */
                    iRecvLen = recv(iNewSocketSever, ucRecvBuf, 999, 0); /* flags普通情况下置为0 */
                    if (iRecvLen <= 0)
                    {
                        /* recv出错(-1)或连接关闭(0) */
                        close(iNewSocketSever);
                        printf("Disconnected!\n");
                        return -1;
                    }
                    else
                    {
                        ucRecvBuf[iRecvLen] = '\0';
                        printf("The recv msg is : %s\n", ucRecvBuf);
                    }
                }
            }
            else
            {
                /* 父进程代码 */
                close(iNewSocketSever);     /* 父进程关闭已连接描写叙述符尤为重要 */
            }
        }
    }
    close(iSocketSever);
    return 0;
}

注意，假设使用了SOCK_STREAM套接字。就不能保证一次可以接受到整个数据。

普通情况是要在循环中重复读。直到返回0.

UDPclient：

/* 基于UDP协议的socket编程client代码 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
/* client:
 * socket-->connect-->send/recv
 */
#define SERVER_PORT 8888
int main(int argc, char **argv)
{
    int iRet;
    int iSocketClient;
    struct sockaddr_in tSocketServerAddr;
    int iSendLen;
    unsigned char ucSendBuf[1000];
    if (argc != 2)
    {
        printf("Usage:\n");
        printf("%s <server_ip>\n", argv[0]);
        return -1;
    }
    /* 1. 建立socket */
    iSocketClient = socket(AF_INET, SOCK_DGRAM, 0);
    /* 2. 不会建立真正的连接，仅仅是让socket描写叙述符中带有服务器地址，
     * 假设不使用connect函数，则应该使用sento函数发送数据
     */
    tSocketServerAddr.sin_family = AF_INET;            /* recommend */
    tSocketServerAddr.sin_port   = htons(SERVER_PORT); /* host to net short */
    if (inet_aton(argv[1], &tSocketServerAddr.sin_addr) == 0) /* 字符串转服务器IP */
    {
        printf("Invalid server IP\n");
        return -1;
    }
    bzero(tSocketServerAddr.sin_zero, 8);
    /* UDP中不须要建立连接，但这里使用connect是能够将地址绑定到iSocketClient上，send函数中就不须要地址信息了 */
    iRet = connect(iSocketClient, (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
    if (iRet == -1)
    {
        printf("connect error\n");
        return -1;
    }
    while (1)
    {
        if (fgets(ucSendBuf, 999, stdin))
        {
            /* send函数发送数据 */
            iSendLen = send(iSocketClient, ucSendBuf, strlen(ucSendBuf), 0);
            if (iSendLen == -1)
            {
                /* 函数出错 */
                close(iSocketClient);
                return -1;
            }
        }
    }
    return 0;
}

UDP服务端：

/* 基于UDP协议的socket编程server端代码 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
/* server:
 * socket-->bind-->sendto/recvfrom
 */
#define SERVER_PORT 8888
int main(int argc, char **argv)
{
    int iRet;
    int iAddrLen;
    int iSocketSever;
    struct sockaddr_in tSocketServerAddr;
    struct sockaddr_in tSocketClientAddr;
    int iRecvLen;
    unsigned char ucRecvBuf[1000];
    /* 1. 建立socket
     * AF_INET: IPv4 Internet protocols
     * SOCK_DGRAM: UDP协议
     * 0: 通常赋值
     */
    iSocketSever = socket(AF_INET, SOCK_DGRAM, 0);
    if (iSocketSever == -1)
    {
        printf("socket error\n");
        return -1;
    }
    /* 2. 配置socket
     * 设置监听本机的哪个IP，端口
     */
    tSocketServerAddr.sin_family      = AF_INET;            /* recommend */
    tSocketServerAddr.sin_port        = htons(SERVER_PORT); /* host to net short */
    tSocketServerAddr.sin_addr.s_addr = htonl(INADDR_ANY);  /* 填入本机全部IP */
    bzero(tSocketServerAddr.sin_zero, 8);
    iRet = bind(iSocketSever, (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
    if (iRet == -1)
    {
        printf("bind error\n");
        return -1;
    }
    while (1)
    {
        /* 接收client数据，地址信息放在tSocketClientAddr结构体中 */
        iAddrLen = sizeof(struct sockaddr);
        iRecvLen = recvfrom(iSocketSever, ucRecvBuf, 999, 0, (struct sockaddr *)&tSocketClientAddr, &iAddrLen);
        if (iRecvLen > 0)
        {
            ucRecvBuf[iRecvLen] = '\0';
            printf("Get msg from %s : %s\n", inet_ntoa(tSocketClientAddr.sin_addr), ucRecvBuf);
        }
    }
    close(iSocketSever);
    return 0;
}

UDPclient（无connect函数）：

/* 基于UDP协议的socket编程client代码 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
/* client:
 * socket-->sendto/recvfrom
 */
#define SERVER_PORT 8888
int main(int argc, char **argv)
{
    int iRet;
    int iSocketClient;
    struct sockaddr_in tSocketServerAddr;
    int iSendLen;
    unsigned char ucSendBuf[1000];
    if (argc != 2)
    {
        printf("Usage:\n");
        printf("%s <server_ip>\n", argv[0]);
        return -1;
    }
    /* 1. 建立socket */
    iSocketClient = socket(AF_INET, SOCK_DGRAM, 0);
    /* 2. 设置服务器地址 */
    tSocketServerAddr.sin_family = htonl(AF_INET);     /* recommend */
    tSocketServerAddr.sin_port   = htons(SERVER_PORT); /* host to net short */
    if (inet_aton(argv[1], &tSocketServerAddr.sin_addr) == 0) /* 字符串转服务器IP */
    {
        printf("Invalid server IP\n");
        return -1;
    }
    bzero(tSocketServerAddr.sin_zero, 8);
    while (1)
    {
        if (fgets(ucSendBuf, 999, stdin))
        {
            /* sendto函数发送数据 */
            iSendLen = sendto(iSocketClient, ucSendBuf, strlen(ucSendBuf), 0,
                              (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
            if (iSendLen == -1)
            {
                /* 函数出错 */
                close(iSocketClient);
                return -1;
            }
        }
    }
    return 0;
}

UDP服务端（无connect函数）：

/* 基于UDP协议的socket编程server端代码 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
/* server:
 * socket-->bind-->sendto/recvfrom
 */
#define SERVER_PORT 8888
int main(int argc, char **argv)
{
    int iRet;
    int iAddrLen;
    int iSocketSever;
    struct sockaddr_in tSocketServerAddr;
    struct sockaddr_in tSocketClientAddr;
    int iRecvLen;
    unsigned char ucRecvBuf[1000];
    /* 1. 建立socket
     * AF_INET: IPv4 Internet protocols
     * SOCK_DGRAM: UDP协议
     * 0: 通常赋值
     */
    iSocketSever = socket(AF_INET, SOCK_DGRAM, 0);
    if (iSocketSever == -1)
    {
        printf("socket error\n");
        return -1;
    }
    /* 2. 配置socket
     * 设置监听本机的哪个IP，端口
     */
    tSocketServerAddr.sin_family      = AF_INET;            /* recommend */
    tSocketServerAddr.sin_port        = htons(SERVER_PORT); /* host to net short */
    tSocketServerAddr.sin_addr.s_addr = INADDR_ANY;         /* 填入本机全部IP */
    bzero(tSocketServerAddr.sin_zero, 8);
    iRet = bind(iSocketSever, (const struct sockaddr *)&tSocketServerAddr, sizeof(struct sockaddr));
    if (iRet == -1)
    {
        printf("bind error\n");
        return -1;
    }
    while (1)
    {
        /* 接收client数据。地址信息放在tSocketClientAddr结构体中 */
        iAddrLen = sizeof(struct sockaddr);
        iRecvLen = recvfrom(iSocketSever, ucRecvBuf, 999, 0, (struct sockaddr *)&tSocketClientAddr, &iAddrLen);
        if (iRecvLen > 0)
        {
            ucRecvBuf[iRecvLen] = '\0';
            printf("Get msg from %s : %s\n", inet_ntoa(tSocketClientAddr.sin_addr), ucRecvBuf);
        }
    }
    close(iSocketSever);
    return 0;
}

參考：

《unix环境高级编程》第16章。

时间： 2024-03-31 01:21:15

【Linux编程】socket编程的相关文章

Linux下Socket编程

http://blog.chinaunix.net/uid-20733992-id-3450058.html 原文地址:Linux下Socket编程 作者:yulianliu1218 Linux下Socket编程 什么是Socket Socket接口是TCP/IP网络的API,Socket接口定义了许多函数或例程,程序员可以用它们来开发TCP/IP网络上的应用程序.要学Internet上的TCP/IP网络编程,必须理解Socket接口. Socket接口设计者最先是将接口放在Unix操作系统里面

Linux下Socket编程的端口问题( Bind error: Address already in use )

Linux下Socket编程的端口问题( Bind error: Address already in use ) 在进行linux网络编程时,每次修改了源代码并再次编译运行时,常遇到下面的地使用错误: Bind error: Address already in use 虽然用Ctrl+C强制结束了进程,但错误依然存在,用netstat -an |grep 5120和ps aux |grep 5120都还能看到刚才用Ctrl+C“强制结束”了的进程,端口还是使用中,只好每次用kill结束进程,

Linux下socket编程，附带tcp例子

1.网络中进程之间如何通信? 本地的进程间通信(IPC)有很多种方式,但可以总结为下面4类: 消息传递(管道.FIFO.消息队列) 同步(互斥量.条件变量.读写锁.文件和写记录锁.信号量) 共享内存(匿名的和具名的) 远程过程调用(Solaris门和Sun RPC) 但这些都不是本文的主题!我们要讨论的是网络中进程之间如何通信?首要解决的问题是如何唯一标识一个进程,否则通信无从谈起!在本地可以通过进程PID来唯一标识一个进程,但是在网络中这是行不通的.其实TCP/IP协议族已经帮我们解决了这个问

Linux下socket编程(转载自http://blog.csdn.net/hguisu/article/details/7445768/)

Linux的SOCKET编程详解 1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统.由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进 程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如 UNIX BSD有:管道(pipe).命名管道(named pipe)软中断信号(signal) UNIX system V有:消息(message).共享存储区(shared memory)和信号量(semaphore)等. 他们都仅限于用在本机进程之间通信.网间进

Linux的SOCKET编程详解（转）

Linux的SOCKET编程详解 1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统.由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进 程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如 UNIX BSD有:管道(pipe).命名管道(named pipe)软中断信号(signal) UNIX system V有:消息(message).共享存储区(shared memory)和信号量(semaphore)等. 他们都仅限于用在本机进程之间通信.网间进

Linux下socket编程基本知识

本文档主要讲解了Linux下socket编程的一些基本知识,主要包括套接字和字节序的概念,以及一些常用的结构体和函数. 本文是在网易云课堂学习过程中的记录,这个老师讲得很不错,推荐大家围观. Linux网络编程 Linux网络编程|人工智能物联网 1.概念 1.1套接字(socket) Socket(套接字)是一种通讯机制,它包含一整套的调用接口和数据结构的定义,它给应用进程提供了使用如TCP/UDP等网络协议进行网络通讯的手段. Linux中的网络编程通过socket接口实现,socket既是

[转]Linux的SOCKET编程详解

From : http://blog.csdn.net/hguisu/article/details/7445768 1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统.由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进 程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如 UNIX BSD有:管道(pipe).命名管道(named pipe)软中断信号(signal) UNIX system V有:消息(message).共享存储区(shared mem

Linux的SOCKET编程详解

1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统.由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进 程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如 UNIX BSD有:管道(pipe).命名管道(named pipe)软中断信号(signal) UNIX system V有:消息(message).共享存储区(shared memory)和信号量(semaphore)等. 他们都仅限于用在本机进程之间通信.网间进程通信要解决的是不同主机进程间的相

Linux C Socket编程原理及简单实例

原文:http://www.cnblogs.com/xudong-bupt/archive/2013/12/29/3483059.html 部分转自:http://goodcandle.cnblogs.com/archive/2005/12/10/294652.aspx 1.   什么是TCP/IP.UDP? 2.   Socket在哪里呢? 3.   Socket是什么呢? 4.   有很多的框架,为什么还在从Socket开始? 5.   Linux C Socket简单示例 1.什么是TCP

linux c socket编程

1. 网络中进程之间如何通信 进 程通信的概念最初来源于单机系统.由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进 程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如 UNIX BSD有:管道(pipe).命名管道(named pipe)软中断信号(signal) UNIX system V有:消息(message).共享存储区(shared memory)和信号量(semaphore)等. 他们都仅限于用在本机进程之间通信.网间进程通信要解决的是不同主机进程间的相