环境:
Centos 6.5+gcc (GCC) 4.8.2+kernel 2.6.32+cmake version 2.8.12.2
目标:完成Linux下TCP通信基础版本,可以实现客户端对服务器端的通信。
服务器端:
CMakeLists.txt:
cmake_minimum_required(VERSION 2.8)
#project name
project(socket_demo)
set(CMAKE_CXX_COMPILER "g++")
#set compiler for c++ language
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++0x -pthread -lrt -D_GLIBCXX_USE_NANOSLEEP")
#source files(can add source files manually)
#set(SOURCE_FILES main.cpp ThostFtdcMdApi.h ThostFtdcTraderApi.h ThostFtdcUserApiDataType.h ThostFtdcUserApiStruct.h MdSpi.cpp MdSpi.h TdSpi.cpp TdSpi.h CTP_Manager.cpp CTP_Manager.h Login.h Order.cpp Order.h User.cpp User.h Utils.cpp Utils.h DBManager.h DBManager.cpp Trader.h Trader.cpp FutureAccount.h FutureAccount.cpp Strategy.h Strategy.cpp Algorithm.h Algorithm.cpp)
#source directory(add source files automatically)
aux_source_directory(. SOURCE_FILES)
#set extern libraries
#set(LIBRARIES libthostmduserapi.so libthosttraderapi.so libmongoclient.so libboost_thread.so libboost_system.so libboost_regex.so)
#add execute file
add_executable(socket_server ${SOURCE_FILES})
#add link library
#target_link_libraries(quant_ctp_XTrader ${LIBRARIES})
socket_server.c:
#include <netdb.h>
#include <sys/socket.h>
#include <unistd.h>
#include <string.h>
#include <stdio.h>
#include <memory.h>
#include <signal.h>
#include <time.h>
#define MAXCONNECTIONS 100
int sockfd;
void sig_handler(int signo) {
if (signo == SIGINT) {
printf("server close\n");
close(sockfd);
exit(1);
}
}
/*输出连接上来的客户端的相关信息*/
void out_addr(struct sockaddr_in *clientaddr) {
//将端口从网络字节序转换成主机字节序
int port = ntohs(clientaddr->sin_port);
char ip[16];
memset(ip, 0, sizeof(ip));
//将ip地址从网络字节序转换成点分十进制
inet_ntop(AF_INET, &clientaddr->sin_addr.s_addr, ip, sizeof(ip));
printf("client: %s(%d) connected\n", ip, port);
}
/*输出服务器端时间*/
void do_service(int fd) {
size_t len;
char buff[20];
if ((len = read(fd, buff, 20)) < 0) {
perror("read error");
}
//获得系统时间
long t = time(0);
char *s = ctime(&t);
size_t size = strlen(s) * sizeof(char);
//将服务器端获得的系统时间写回到客户端
if (write(fd, s, size) != size) {
perror("write error");
}
}
int main(int argc, char *argv[]) {
if (argc < 2) {
printf("usage: %s #port\n", argv[0]);
exit(1);
}
if (signal(SIGINT, sig_handler) == SIG_ERR) {
perror("signal sigint error");
exit(1);
}
/*步骤1:创建socket(套接字)*/
sockfd = socket(AF_INET, SOCK_STREAM, 0);
/*步骤2:将socket和地址(包括ip,port)进行绑定*/
struct sockaddr_in serveraddr;
memset(&serveraddr, 0, sizeof(serveraddr));
/*向地址中填入ip,port,internet地址簇类型*/
serveraddr.sin_family = AF_INET; //ipv4
serveraddr.sin_port = htons(atoi(argv[1])); //port
serveraddr.sin_addr.s_addr = INADDR_ANY; //接收所有网卡地址
if (bind(sockfd, (struct sockaddr *)&serveraddr, sizeof(serveraddr)) < 0) {
perror("bind error");
exit(1);
}
/*步骤3:调用listen函数启动监听(指定port监听)
通知系统去接受来自客户端的连接请求
第二个参数:指定队列的长度*/
if (listen(sockfd, MAXCONNECTIONS) < 0) {
perror("listen error");
exit(1);
}
/*步骤4:调用accept函数从队列中获得一个客户端的连接请求,
并返回新的socket描述符*/
struct sockaddr_in clientaddr;
socklen_t clientaddr_len = sizeof(clientaddr);
while (1)
{
int fd = accept(sockfd, (struct sockaddr *)&clientaddr, &clientaddr_len);
if (fd < 0) {
perror("accept error");
continue;
}
/*步骤5:调用IO函数(read/write)和连接的客户端进行双向的通信*/
out_addr(&clientaddr);
do_service(fd);
/*步骤6:关闭socket*/
close(fd);
}
return 0;
}
编译方式:
cmake . make
客户端:
CMakeLists.txt:
cmake_minimum_required(VERSION 2.8)
#project name
project(socket_demo)
set(CMAKE_CXX_COMPILER "g++")
#set compiler for c++ language
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++0x -pthread -lrt -D_GLIBCXX_USE_NANOSLEEP")
#source files(can add source files manually)
#set(SOURCE_FILES main.cpp ThostFtdcMdApi.h ThostFtdcTraderApi.h ThostFtdcUserApiDataType.h ThostFtdcUserApiStruct.h MdSpi.cpp MdSpi.h TdSpi.cpp TdSpi.h CTP_Manager.cpp CTP_Manager.h Login.h Order.cpp Order.h User.cpp User.h Utils.cpp Utils.h DBManager.h DBManager.cpp Trader.h Trader.cpp FutureAccount.h FutureAccount.cpp Strategy.h Strategy.cpp Algorithm.h Algorithm.cpp)
#source directory(add source files automatically)
aux_source_directory(. SOURCE_FILES)
#set extern libraries
#set(LIBRARIES libthostmduserapi.so libthosttraderapi.so libmongoclient.so libboost_thread.so libboost_system.so libboost_regex.so)
#add execute file
add_executable(socket_client ${SOURCE_FILES})
#add link library
#target_link_libraries(quant_ctp_XTrader ${LIBRARIES})
socket_client.c:
#include <netdb.h>
#include <sys/socket.h>
#include <unistd.h>
#include <string.h>
#include <stdio.h>
#include <memory.h>
#include <signal.h>
#include <time.h>
int main(int argc, char *argv[]) {
if (argc < 3) {
printf("usage: %s ip port\n", argv[0]);
exit(1);
}
/*步骤1:创建socket*/
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
perror("socket error");
exit(1);
}
struct sockaddr_in serveraddr;
memset(&serveraddr, 0, sizeof(serveraddr));
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(atoi(argv[2]));
/*将ip地址转换成网络字节序*/
inet_pton(AF_INET, argv[1], &serveraddr.sin_addr.s_addr);
/*步骤2:客户端调用connect函数连接到服务器端*/
if (connect(sockfd, (struct sockaddr *)&serveraddr, sizeof(serveraddr)) < 0) {
perror("connect error");
exit(1);
}
/*步骤3:调用IO函数(read/write)和服务器端进行双向通信*/
char buffer[1024];
memset(buffer, 0, sizeof(buffer));
size_t size;
if ((size = read(sockfd, buffer, sizeof(buffer))) < 0) {
perror("read error");
}
if (write(STDOUT_FILENO, buffer, size) != size) {
perror("write error");
}
/*步骤4:关闭socket*/
close(sockfd);
return 0;
}
编译方式:
cmake . make
运行效果:
客户端访问服务器,服务器给客户端返回当前服务器端时间。
文章的脚注信息由WordPress的wp-posturl插件自动生成

微信扫一扫,打赏作者吧~![[整理][转载]win下网卡抓包发包库Npcap使用](http://www.jyguagua.com/wp-content/themes/begin/timthumb.php?src=http://www.jyguagua.com/wp-content/uploads/2023/08/demo_1-1024x711.jpg&w=280&h=210&zc=1)
![[转载]基础数据char,int,double,string是线程安全的吗?](http://www.jyguagua.com/wp-content/themes/begin/img/random/18.jpg)
![[整理]用c++编写的RDTSC性能计时器](http://www.jyguagua.com/wp-content/themes/begin/timthumb.php?src=http://www.jyguagua.com/wp-content/uploads/2020/12/rdtsc-assembly-example.jpg&w=280&h=210&zc=1)
![[整理]strcmp汇编写法](http://www.jyguagua.com/wp-content/themes/begin/img/random/1.jpg)