上一篇已经做过注释，这一篇直接上代码
[cpp] view
plaincopyprint?
/***************************************************************************************
****************************************************************************************
* FILE : server_test.cc
*
Description :
*
* Copyright (c) 2012 by Liu Yanyun(E-mail:liuyun827@foxmail.com). All Rights
Reserved.
* Without
permission, shall not be used for any commercial purpose
*
*
History:
* Version
Name
Date
Description
0.1 Liu
Yanyun 2012/12/03
Initial Version
****************************************************************************************
****************************************************************************************/
#include "socket.h"
#include
"log_trace.h"
#include "socket_addr.h"
#include
"socket_base.h"
#include "event_loop.h"
#include
<iostream>
using namespace std;
int main()
{
Socket *ser =
Socket::create();
bool ret =
ser->open("dgram://unix.domain.ipc.1");
char
buf[100] = {0};
char addr[128] = {0};
ser->recv(buf, sizeof(buf), addr);
printf("from:%s;buf:%s\n", addr, buf);
ser->send(buf, strlen(buf), addr);
Socket::destroy(ser);
return 0;
}
/***************************************************************************************
****************************************************************************************
*
FILE : server_test.cc
* Description :
*
* Copyright (c) 2012 by Liu
Yanyun(E-mail:liuyun827@foxmail.com). All Rights
Reserved.
*
Without permission, shall not be used for any commercial purpose
*
*
History:
* Version Name
Date Description
0.1 Liu
Yanyun 2012/12/03 Initial Version
****************************************************************************************
****************************************************************************************/
#include "socket.h"
#include "log_trace.h"
#include
"socket_addr.h"
#include "socket_base.h"
#include
"event_loop.h"
#include <iostream>
using namespace std;
int main()
{
Socket *ser = Socket::create();
bool ret
= ser->open("dgram://unix.domain.ipc.1");
char buf[100] = {0};
char addr[128] = {0};
ser->recv(buf, sizeof(buf), addr);
printf("from:%s;buf:%s\n", addr, buf);
ser->send(buf, strlen(buf), addr);
Socket::destroy(ser);
return 0;
}
[cpp] view
plaincopyprint?
/***************************************************************************************
****************************************************************************************
* FILE : client_test.cc
*
Description :
*
* Copyright (c) 2012 by Liu Yanyun(E-mail:liuyun827@foxmail.com). All Rights
Reserved.
* Without
permission, shall not be used for any commercial purpose
*
*
History:
* Version
Name
Date
Description
0.1 Liu
Yanyun 2012/12/03
Initial Version
****************************************************************************************
****************************************************************************************/
#include "socket.h"
#include
"log_trace.h"
#include "socket_addr.h"
#include
"socket_base.h"
#include <iostream>
using namespace std;
int main()
{
Socket *clt = Socket::create();
bool ret =
clt->open("dgram://unix.domain.ipc.2");
ret = ret;
char buf[100] = {"hello"};
char addr[128]
= {0};
clt->send(buf, strlen(buf),
"dgram://unix.domain.ipc.1");
clt->recv(buf,
sizeof(buf), addr);
printf("from:%s;buf:%s\n", addr,
buf);
sleep(2);
Socket::destroy(clt);
return
0;
}
/***************************************************************************************
****************************************************************************************
*
FILE : client_test.cc
* Description :
*
* Copyright (c) 2012 by Liu
Yanyun(E-mail:liuyun827@foxmail.com). All Rights
Reserved.
*
Without permission, shall not be used for any commercial purpose
*
*
History:
* Version Name
Date Description
0.1 Liu
Yanyun 2012/12/03 Initial Version
****************************************************************************************
****************************************************************************************/
#include "socket.h"
#include "log_trace.h"
#include
"socket_addr.h"
#include "socket_base.h"
#include <iostream>
using namespace std;
int main()
{
Socket *clt = Socket::create();
bool ret
= clt->open("dgram://unix.domain.ipc.2");
ret = ret;
char buf[100] = {"hello"};
char addr[128] = {0};
clt->send(buf, strlen(buf), "dgram://unix.domain.ipc.1");
clt->recv(buf, sizeof(buf), addr);
printf("from:%s;buf:%s\n", addr, buf);
sleep(2);
Socket::destroy(clt);
return
0;
}起两个shell结果为:
./server_test
from:dgram://unix.domain.ipc.2;buf:hello
./client_test
from:dgram://unix.domain.ipc.1;buf:hello
上面是使用unix域套接字进程测试;修改地址为ip:port形式可以转为inet域。
对于数据包式的通信，只需要各自打开自身的地址，然后就可以根据地址收发数据了；而在上一篇中对于字节流方式服务器端要先打开进行监听，然后客户端去连接，服务器端接受连接以后才可以进行通信。