|
// CDomain.h #ifndef _DOMAIN_H_ #define _DOMAIN_H_ #include <stdio.h> #include <string.h> #include <unistd.h> class CDomain{ public: int create_domain_socket(const char *path); int unix_connect(char *client_path, char *server_path); private: }; #endif ================================================================= // CDomain.cpp #include <unistd.h> #include <stdlib.h> #include <fcntl.h> #include <errno.h> #include <sys/un.h> #include <netdb.h> #include <arpa/inet.h> #include <sys/syscall.h> #include <sys/socket.h> #include <netinet/in.h> #include "domain.h" int CDomain::create_domain_socket(const char *path) { int socket_fd = 0; struct sockaddr_un addr; int ret = 0; if(path == NULL) { return -1; } socket_fd = socket(AF_LOCAL, SOCK_DGRAM, 0); if(socket_fd < 0) { return -1; } bzero(&addr, sizeof(struct sockaddr_un)); addr.sun_family = AF_LOCAL; strcpy(addr.sun_path, path); addr.sun_path[sizeof(addr.sun_path) - 1] = 0; unlink(path); ret = bind(socket_fd, (struct sockaddr *)&addr, sizeof(struct sockaddr_un)); if(ret != 0) { close(socket_fd); return -1; } return socket_fd; } int CDomain::unix_connect(char *client_path, char *server_path) { struct sockaddr_un servaddr, g_cliaddr; //socket连接变量 int sockfd; //socket连接描述 int ret = -1; if(NULL == client_path || NULL == server_path) { return -1; } sockfd = socket( AF_LOCAL, SOCK_DGRAM, 0 ); if ( sockfd < 0 ) { return -1; } //清空连接记录 bzero( &servaddr, sizeof( servaddr ) ); bzero( &g_cliaddr, sizeof(g_cliaddr) ); //注册客户 g_cliaddr.sun_family = AF_LOCAL; strcpy( g_cliaddr.sun_path, client_path ); unlink( client_path ); //绑定socket连接信息，如果绑定失败则返回error if ( -1 == bind( sockfd, (struct sockaddr*)&g_cliaddr, sizeof( g_cliaddr ) ) ) { goto result; } //注册域 servaddr.sun_family = AF_LOCAL; strcpy( servaddr.sun_path, server_path ); //绑定信息，失败则返回error if ( -1 == connect(sockfd, (struct sockaddr *)&servaddr, sizeof( servaddr ) ) ) { goto result; } ret = 0; result: if(ret < 0) { close(sockfd); return -1; } return sockfd; } ======================================================== // client.cpp #include "domain.h" int main(int argc, char *argv[]) { if(argc < 2) { printf("please input 2 param\n"); return -1; } int len = -1; char buf[1024] = {"wahahahahah"}; CDomain client; char client_path[] = {"tanxiaohai11"}; char server_path[] = {"tanhuifang"}; int fd = client.unix_connect(client_path, server_path); if(fd < 0) { printf("err fd\n"); return 0; } while(1) { len = write(fd, buf, sizeof(buf)); if(0 < len) { printf("T -----write success len[%d]\n", len); } usleep(2000*1000); } return 0; } =========================================== //server.cpp #include "domain.h" int main() { int len = -1; char buf[1024] = {}; CDomain client; char client_path[] = {"tanxiaohai"}; char server_path[] = {"tanhuifang"}; int fd = client.create_domain_socket(server_path); if(fd < 0) { printf("err fd\n"); return 0; } while(1) { len = read(fd,buf,1024); if(0 < len) { printf("T --server recv---[%s]\n", buf); } usleep(20*1000); } return 0; } |
|
|
