유닉스 소켓 통신 방식

unix socket

#include "sys/un.h"
#include "netinet/in.h"
#include "sys/socket.h"
#include 
#include 
#include 
#include "string.h"
#include "pthread.h"
#include 
#include 
#include 
#include 

#define LISTEN_PATH "/data/test_socket"
static int  listenFd = 0;

int init()
{
    int  rcv_len;
    int on=1;
    struct sockaddr_un servAddr;
    unlink(LISTEN_PATH);
    INFO("init");
    servAddr.sun_family = AF_UNIX;
    strcpy(servAddr.sun_path, LISTEN_PATH);
    if((listenFd = socket(AF_UNIX, SOCK_DGRAM,0)) < 0) {
        INFO("%s", strerror(errno));
        return -1;
    }
    if((setsockopt(listenFd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)))<0) {
        INFO("%s", strerror(errno));
        return -1;
    }
    if(::bind(listenFd, (struct sockaddr*)&servAddr,sizeof(servAddr)) < 0){
        close(listenFd);
        INFO("%s", strerror(errno));
        return -1;
    }
    INFO("listenfd %d",listenFd);
    return 0;
}

bool Start_Server()
{
	init();
	int rcv_len;
	const int BUFSIZE = 1024*1024;
	while(true) {
				char *socket_buf = (char *)malloc(BUFSIZE);
				fd_set rs;
				FD_ZERO(&rs);
				FD_SET(listenFd, &rs);
				int res = select(listenFd + 1, &rs, NULL, NULL, NULL);
				if (FD_ISSET(listenFd, &rs)) {
					if((rcv_len = recvfrom(listenFd, socket_buf, BUFSIZE, 0, NULL, NULL)) > 0) {
						//memcpy(buf, socket_buf, rcv_len);
						INFO( "live_play_add_ts_data------------->>>>>>>>>>>> dataSize = %d
", rcv_len);
			            int ret = live_play_add_ts_data((unsigned char*)socket_buf,rcv_len);
						free(socket_buf);
						continue;
					}
					INFO("recvfrom waitEvent: %d",listenFd);
				}
    }
    free(socket_buf);
	return true;
}
		

client 측 코드는 다음과 같습니다.

#include "sys/un.h"
#include "netinet/in.h"
#include "sys/socket.h"

const char *LOCAL_SOCKET_PATH = "/data/test_socket";

int     local_socket;

int main(int argc, char *argv[])
{

   local_socket = socket(AF_UNIX,SOCK_DGRAM,0);
   if (local_socket < 0) {
	printf("create local socket fail");
   }
	
    struct sockaddr_un servaddr;
    socklen_t socklen = sizeof(struct sockaddr_un);
    memset(&servaddr,0,sizeof(servaddr));

    servaddr.sun_family = AF_UNIX;
    strcpy(servaddr.sun_path, LOCAL_SOCKET_PATH);
	sendto(local_socket, buf, data_len, 0, (struct sockaddr*)&servaddr, socklen);
	

    return 0;
}