如何使用C語言實現(xiàn)本地socke通訊

這篇文章主要介紹了如何使用C語言實現(xiàn)本地socke通訊，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

一、概述

　　使用本地socket通訊可以實現(xiàn)進(jìn)程之間的通訊。

　　相關(guān)函數(shù)描述如下：

int socket(int domain, int type, int protocol);

函數(shù)說明: 創(chuàng)建本地域socket

函數(shù)參數(shù):    

    domain: AF_UNIX or AF_LOCAL

    type: SOCK_STREAM或者SOCK_DGRAM

    protocol: 0 表示使用默認(rèn)協(xié)議

函數(shù)返回值:

    成功: 返回文件描述符.

    失敗: 返回-1, 并設(shè)置errno值.

創(chuàng)建socket成功以后, 會在內(nèi)核創(chuàng)建緩沖區(qū), 下圖是客戶端和服務(wù)端內(nèi)核緩沖區(qū)示意圖.

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

函數(shù)說明: 綁定套接字

函數(shù)參數(shù):

    socket: 由socket函數(shù)返回的文件描述符

    addr: 本地地址

    addlen: 本地地址長度

函數(shù)返回值:

    成功: 返回文件描述符.

    失敗: 返回-1, 并設(shè)置errno值.

需要注意的是: bind函數(shù)會自動創(chuàng)建socket文件, 若在調(diào)用bind函數(shù)之前socket文件已經(jīng)存在, 則調(diào)用bind會報錯, 可以使用unlink函數(shù)在bind之前先刪除文件.

struct sockaddr_un {

    sa_family_t sun_family;  /* AF_UNIX or AF_LOCAL*/

    char sun_path[108];  /* pathname */

};

　　整體使用步驟和網(wǎng)絡(luò)通訊的socket是差不多的，如下所示：

tcp的本地套接字服務(wù)器流程：

    創(chuàng)建套接字  socket(AF_UNIX,SOCK_STREAM,0)

    綁定 struct sockaddr_un &強(qiáng)轉(zhuǎn)

    偵聽 listen 

    獲得新連接 accept 

    循環(huán)通信 read-write 

    關(guān)閉文件描述符 close

tcp本地套接字客戶端流程：

    調(diào)用socket創(chuàng)建套接字

    調(diào)用bind函數(shù)將socket文件描述和socket文件進(jìn)行綁定.

        不是必須的, 若無顯示綁定會進(jìn)行隱式綁定，但服務(wù)器不知道誰連接了.

    調(diào)用connect函數(shù)連接服務(wù)端

    循環(huán)通信read-write

    關(guān)閉文件描述符 close

二、代碼示例

　　1.服務(wù)端代碼示例

//本地socket通訊服務(wù)端

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <unistd.h>

#include <arpa/inet.h>

#include <netinet/in.h>

#include <sys/un.h>

int main(){

    //創(chuàng)建socket

    int lfd = socket(AF_UNIX,SOCK_STREAM,0);

    if(lfd<0){

        perror("socket error");

        return -1;

    }

    //刪除socket文件，避免bind失敗

    unlink("./server.sock");

    //綁定

    struct sockaddr_un serv;

    bzero(&serv,sizeof(serv));

    serv.sun_family = AF_UNIX;

    strcpy(serv.sun_path,"./server.sock");

    int ret = bind(lfd,(struct sockaddr *)&serv,sizeof(serv));

    if(ret<0){

        perror("bind error");

        return -1;

    }

    //監(jiān)聽

    listen(lfd,10);

    //接收新的鏈接-accept

    struct sockaddr_un client;

    bzero(&client,sizeof(client));

    socklen_t len = sizeof(client);

    int cfd = accept(lfd,(struct sockaddr*)&client,&len);

    if(cfd<0){

        perror("accept error");

        return -1;

    }

    printf("cient->[%s]\n",client.sun_path);

    int n;

    char buf[1024];

    while(1){

        //讀取數(shù)據(jù)

        memset(buf,0x00,sizeof(buf));

        n = read(cfd,buf,sizeof(buf));

        if(n<=0){

            printf("read error or client close ,n=[%d]\n",n);

            break;

        }

        printf("n=[%d],buf=[%s]\n",n,buf);

        //發(fā)送數(shù)據(jù)

        write(cfd,buf,n);

    }

    //關(guān)閉套接字

    close(lfd);

    return 0;

}

　　2.客戶端代碼示例

//本地socket通信客戶端

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <unistd.h>

#include <arpa/inet.h>

#include <netinet/in.h>

#include <sys/un.h>

int main(){

    //創(chuàng)建socket

    int cfd = socket(AF_UNIX,SOCK_STREAM,0);

    if(cfd<0){

        perror("socket error");

        return -1;

    }

    //刪除socket文件，避免bind失敗

    unlink("./client.sock");

    //綁定

    struct sockaddr_un client;

    bzero(&client,sizeof(client));

    client.sun_family= AF_UNIX;

    strcpy(client.sun_path,"./client.sock");

    int ret = bind(cfd,(struct sockaddr*)&client,sizeof(client));

    if(ret<0){

        perror("bind error");

        return -1;

    }

    struct sockaddr_un serv;

    bzero(&serv,sizeof(serv));

    serv.sun_family = AF_UNIX;

    strcpy(serv.sun_path,"./server.sock");

    ret = connect(cfd,(struct sockaddr*)&serv,sizeof(serv));

    if(ret<0){

        perror("connect error");

        return -1;

    }

    int n;

    char buf[1024];

    while(1){

        memset(buf,0x00,sizeof(buf));

        n = read(STDIN_FILENO,buf,sizeof(buf));

        //發(fā)送數(shù)據(jù)

        write(cfd,buf,n);

        //讀取數(shù)據(jù)

        memset(buf,0x00,sizeof(buf));

        n = read(cfd,buf,sizeof(buf));

        if(n<=0){

            printf("read error or client close ,n=[%d]",n);

            break;

        }

        printf("n=[%d],buf=[%s]",n,buf);

    }

    close(cfd);

    return 0;

}

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“如何使用C語言實現(xiàn)本地socke通訊”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習(xí)!