tcp客户端示例
?| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 |
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
typedef struct _NSS_HEADER
{
unsigned short ProtocolVersion; /* 协议版本信息 */
unsigned short MsgType; /* 消息类型 */
unsigned short TransactionNo; /* 传输编号 */
unsigned short PacketLength; /* 数据包长度,包括Header */
}NSS_HEADER;
int str_echo(int sockfd, unsigned short no)
{
ssize_t readLen;
ssize_t writeLen;
char buf[8];
NSS_HEADER *hdr = (NSS_HEADER*)buf;
memset( hdr, 0, sizeof(NSS_HEADER) );
hdr->TransactionNo = no;
// 写数据
int nWriteLen = 0;
while ( true )
{
writeLen = write(sockfd, &buf[nWriteLen], sizeof(NSS_HEADER)-nWriteLen);
// printf( "write %d/n", writeLen);
if (writeLen < 0 && errno == EINTR)
{
continue;
}
else if ( writeLen < 0 )
{
perror ( "write:" );
return -1;
}
nWriteLen += writeLen;
// 已写完，直接返回
if (nWriteLen >= sizeof(NSS_HEADER) )
{
break;
}
}
printf( "send data successed. trans no: %d/n", no );
// 读数据
int nReadLen = 8;
while ( true )
{
readLen = read(sockfd, buf, nReadLen);
// printf( "read: %d/n", readLen );
if (readLen < 0 && errno == EINTR)
{
continue;
}
else if ( readLen <= 0 )
{
perror( "read:");
return -1;
}
else
{
nReadLen -= readLen;
if (nReadLen <= 0 )
{
break;
}
}
}
printf( "read response successed./n" );
return 0;
}
int main(int argc, char **argv)
{
printf("client ip: %s/n", argv[1]);
printf("client port: %s/n", argv[2]);
printf("server ip: %s/n", argv[3]);
printf("server port: %s/n", argv[4]);
printf("/n service starting.../n/n");
while( true )
{
int socketFd;
struct sockaddr_in svrAddr;
struct sockaddr_in localAddr;
socketFd = socket (AF_INET, SOCK_STREAM, 0);
if ( -1 == socketFd )
{
perror( "socket:" );
continue;
}
// 设置地址可复用
int option = 1;
setsockopt( socketFd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option) );
// 客户端IP
memset(&localAddr, 0, sizeof(localAddr));
localAddr.sin_family = AF_INET;
localAddr.sin_addr.s_addr = inet_addr( argv[1]);
localAddr.sin_port = htons (atoi(argv[2]));
int bindResult = bind(socketFd, (struct sockaddr *) &localAddr, sizeof(localAddr));
if ( -1 == bindResult )
{
perror( "bind:" );
sleep(10);
close(socketFd);
continue;
}
// 服务器IP
memset(&svrAddr, 0, sizeof(svrAddr));
svrAddr.sin_family = AF_INET;
svrAddr.sin_addr.s_addr = inet_addr( argv[3]);
svrAddr.sin_port = htons (atoi(argv[4]));
// 不断重连
int connResult = connect(socketFd, (struct sockaddr *) &svrAddr, sizeof(svrAddr));
if ( -1 == connResult )
{
perror( "connect:" );
sleep(10);
close(socketFd);
continue;
}
printf (" connect %s:%s successed./n", argv[3], argv[4] );
static unsigned short no = 0;
// 连接成功，每分钟发送一次数据
for ( ; ; )
{
if ( -1 == str_echo(socketFd, no++) )
{
break;
}
sleep( 60 );
}
close(socketFd);
}
}
|
tcp服务器源码示例
?| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 |
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
struct _NSS_HEADER
{
unsigned short ProtocolVersion; /* 协议版本信息 */
unsigned short MsgType; /* 消息类型 */
unsigned short TransactionNo; /* 传输编号 */
unsigned short PacketLength; /* 数据包长度,包括Header */
}NSS_HEADER;
void str_echo(int sockfd)
{
ssize_t readLen;
ssize_t writeLen;
char buf[8];
while ( true )
{
readLen = read(sockfd, buf, 8);
if (readLen < 0 && errno == EINTR)
{
continue;
}
else if ( readLen <= 0 )
{
perror( "read:");
return ;
}
printf( "recv data successed. data len: %d/n", readLen );
int nWriteLen = 0;
while ( true )
{
writeLen == write(sockfd, &buf[nWriteLen], readLen-nWriteLen);
if (writeLen < 0 && errno == EINTR)
{
continue;
}
else if ( writeLen < 0 )
{
perror ( "write:" );
return;
}
nWriteLen += writeLen;
// 已写完，直接返回
if (nWriteLen >= readLen )
{
break;
}
}
printf( "send data successed. data len: %d/n", readLen );
}
}
int main(int argc, char **argv)
{
printf( "server ip: %s/n", argv[1] );
printf( "server port: %s/n", argv[2] );
printf( "/nservice starting ... /n/n" );
int listenfd, connfd;
pid_t childpid;
socklen_t clilen;
struct sockaddr_in cliaddr, servaddr;
listenfd = socket (AF_INET, SOCK_STREAM, 0);
if ( -1 == listenfd )
{
perror( "socket:" );
exit(-1);
}
// 设置地址可复用
int option = 1;
setsockopt( listenfd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option) );
memset(&servaddr, 0, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = inet_addr( argv[1]);
servaddr.sin_port = htons (atoi(argv[2]));
int bindResult = bind(listenfd, (struct sockaddr *) &servaddr, sizeof(servaddr));
if ( -1 == bindResult )
{
perror( "bind:" );
exit(-1);
}
int listenResult = listen(listenfd, 5);
if ( -1 == listenResult )
{
perror( "listen:" );
exit(-1);
}
for ( ; ; )
{
clilen = sizeof(cliaddr);
connfd = accept(listenfd, (struct sockaddr *) &cliaddr, &clilen);
if ( -1 == connfd )
{
perror( "accept:" );
continue;
}
printf ("accept %s successed.fd: %d/n", inet_ntoa(cliaddr.sin_addr), connfd );
if ( (childpid = fork()) == 0)
{ /* child process */
close(listenfd); /* close listening socket */
str_echo(connfd); /* process the request */
printf ("disconnect from %d ./n", connfd );
exit (0);
}
}
close(connfd); /* parent closes connected socket */
}
|
如果您对该产品感兴趣，请填写办理（客服微信：xiaoxiongyidong）
发表评论
◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。