文档章节

linux 本地socket

t
 taoanran
发布于 2014/05/08 09:33
字数 422
阅读 125
收藏 3
server 端:

void *recvData(void *arg)
{
    char recvbuf[1024];
    int conn = *(int *)arg;
    while(1)
    {
        memset(recvbuf,0,1024);
        recv(conn, recvbuf, sizeof(recvbuf),0);
    }
}

main 函数:
int listenfd;
int conn;
char sendbuf[1024];
char recvbuf[1024];
char sig_strength[16];
char radio_if[16];
if ((listenfd = socket(PF_UNIX, SOCK_STREAM, 0)) < 0)
    LOGE("socket error");
unlink("/tmp/test_socket"); //地址复用
struct sockaddr_un servaddr;
memset(&servaddr, 0, sizeof(servaddr));
servaddr.sun_family = AF_UNIX;
strcpy(servaddr.sun_path, "/tmp/test_socket");
if (bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)
    LOGE("bind error");
if (listen(listenfd, SOMAXCONN) < 0)
    LOGE("listen error");
while(1)
{
    conn = accept(listenfd, NULL, NULL);
    if (conn == -1)
    {
        if (conn == EINTR)
            continue;
    }
    pthread_create(&thread_socket_recv, NULL, recvData, &conn);
    
    while(1)
    {
        memset(sendbuf,0,1024);
        strncpy(sendbuf,"xxxx, strlen("xxx"));
        send(conn, sendbuf, strlen(sendbuf),0);
    }
    close(conn);
    close(listenfd);
}

client端(非阻塞socket)
typedef struct QMISocket{
int socketfd;
struct timeval timeout;
pthread_mutex_t mMutex;
}QMISocket;
extern QMISocket mSocket;

static int sockConnect()
{
    struct sockaddr_un servaddr;
    int retval ;
    fd_set set;
    int flags;
    int ret=-1;
    
    if ((mSocket.socketfd = socket(PF_UNIX, SOCK_STREAM, 0)) < 0)
        printf("socket error");
    mSocket.timeout.tv_sec = 3;
    mSocket.timeout.tv_usec = 0;
    setsockopt(mSocket.socketfd,SOL_SOCKET,SO_SNDTIMEO,(char *)&(mSocket.timeout),sizeof(struct timeval));
    setsockopt(mSocket.socketfd,SOL_SOCKET,SO_RCVTIMEO,(char *)&(mSocket.timeout),sizeof(struct timeval));
    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sun_family = AF_UNIX;
    strcpy(servaddr.sun_path, "/tmp/test_socket");
    flags = fcntl(mSocket.socketfd, F_GETFL, 0);
    fcntl(mSocket.socketfd, F_SETFL, flags | O_NONBLOCK);
    ret = connect(mSocket.socketfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
    if (0 == ret)
    {
        printf("connected\n");
    }
    else{
        if (errno != EINPROGRESS)
        {
		perror("connect");
		return-1;
	}
	FD_ZERO(&set);
	FD_SET(mSocket.socketfd,&set);
	retval = select(mSocket.socketfd+ 1,NULL, &set,NULL,&mSocket.timeout);
	if(retval==-1)
	{
	    perror("select");
	    return -1;
	}
	else if(retval== 0)
	{
		fprintf(stderr,"timeout\nn");
		printf("%d\n",time(NULL));
		return 0;
	}
	printf("connected\n");
	}
    }
    flags = fcntl(mSocket.socketfd, F_GETFL, 0);
    fcntl(mSocket.socketfd, F_SETFL, flags & ~O_NONBLOCK);
    return mSocket.socketfd;
}

int main()
{
    while(1)//wait the reboot-daemon
    {
        if (sockConnect() > 0)
            break;
        sleep(1);
    }
    while(1)
    {
        char recvbuf[1024]={0};  
        ret = recv(mSocket.socketfd, recvbuf, sizeof(recvbuf),0);
    }
}

这里在recv的时候,如果send端发送非常快,那么可能会导致一次recv到多个数据包的情况,那可需要在每个数据包结尾打上标记,表示一个个数据包。recv根据这些flags去截取每一个数据包

char  *remainBuf = NULL;
remainBuf = recvbuf;
char *tmp = strstr(remainBuf, "@");
memset(key,0,1024);
if (tmp != NULL)
{
	strncpy(key, remainBuf, tmp - remainBuf);
	remainBuf = remainBuf+(tmp - remainBuf)+1;
}


© 著作权归作者所有

共有 人打赏支持
t
粉丝 7
博文 64
码字总数 7186
作品 0
南京
私信 提问
用 python 获取本地/公网 ip 地址

1、Windows下2种方法: 1. 使用拨号上网的话,一般都有一个本地ip和一个外网ip,使用python可以很容易的得到这两个ip 使用gethostbyname和gethostbyname_ex两个函数可以实现 import socket lo...

大数据之路
2012/08/11
0
0
linux 对于websocket 连接限制

linux上放了一个websocket服务端,我本地通过socket 客户端创建连接,测试创建2000个连接也就成功1000左右,linux 文件打开数设置了,tomcat 设置了,linux 配置是单核,内存1g的,这个连接数...

dabing9
2017/07/02
1K
1
Linux下端口复用(SO_REUSEADDR与SO_REUSEPORT)(转载)

http://blog.chinaunix.net/uid-7390305-id-2057201.html 作者:迷失千夏——拾露赏云 解决性参考:Currently, Linux does not allow reuse of same local port for both TCP server and TC......

老汉-憨憨
2014/12/08
0
0
不要在为唯一的port号烦恼了

老式的写法: ServerSocket srv = new ServerSocket(portNumber) 与时俱进的例子: (那也是相对于2008年了) ServerSocket srv = new LocalServerSocket("a.b.c"); 参数其实随便什么string都...

Q_J
2015/05/27
0
0
linux 上 socket 经常无故连接中断

有个情况 请教下呢 就是在内网的linux机器 和 本地的Windows上 socket都是正常的 但是部署在外网 腾讯云 机器上 客户端登陆上去 10分钟以上没得通讯操作 客户端socket就断了,游戏内没有心跳...

SandKing
2017/04/07
465
4

没有更多内容

加载失败,请刷新页面

加载更多

js垃圾回收机制和引起内存泄漏的操作

JS的垃圾回收机制了解吗? Js具有自动垃圾回收机制。垃圾收集器会按照固定的时间间隔周期性的执行。 JS中最常见的垃圾回收方式是标记清除。 工作原理:是当变量进入环境时,将这个变量标记为“...

Jack088
昨天
17
0
大数据教程(10.1)倒排索引建立

前面博主介绍了sql中join功能的大数据实现,本节将继续为小伙伴们分享倒排索引的建立。 一、需求 在很多项目中,我们需要对我们的文档建立索引(如:论坛帖子);我们需要记录某个词在各个文...

em_aaron
昨天
27
0
"errcode": 41001, "errmsg": "access_token missing hint: [w.ILza05728877!]"

Postman获取微信小程序码的时候报错, errcode: 41001, errmsg: access_token missing hint 查看小程序开发api指南,原来access_token是直接当作parameter的(写在url之后),scene参数一定要...

两广总督bogang
昨天
31
0
MYSQL索引

索引的作用 索引类似书籍目录,查找数据,先查找目录,定位页码 性能影响 索引能大大减少查询数据时需要扫描的数据量,提高查询速度, 避免排序和使用临时表 将随机I/O变顺序I/O 降低写速度,占用磁...

关元
昨天
15
0
撬动世界的支点——《引爆点》读书笔记2900字优秀范文

撬动世界的支点——《引爆点》读书笔记2900字优秀范文: 作者:挽弓如月。因为加入火种协会的读书活动,最近我连续阅读了两本论述流行的大作,格拉德威尔的《引爆点》和乔纳伯杰的《疯传》。...

原创小博客
昨天
35
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部