Linux TCP server.c client.c and UDP server.c client.c

#include<stdio.h> #include<stdlib.h> #include<string.h> #include<unistd.h> #include<fcntl.h> #include<sys/types.h> #include<sys/stat.h> //#include"uart_tios.h" #include <sys/socket.h> #include <netinet/in.h>

int sockfd;

void sig_handler(int signo) { if(signo == SIGINT) { close(sockfd); printf("bye bye\n"); exit(EXIT_FAILURE); } }

char sbuf[1281024] = {0}; int main(int argc,char argv[]) {

if(argc < 2)
{
	printf("%s usage: port",argv[0]);
	exit(EXIT_FAILURE);
}


if(signal(SIGINT,sig_handler) == SIG_ERR)
{
	perror("signal failed\n");
	exit(EXIT_FAILURE);
}

sockfd = socket(AF_INET,SOCK_STREAM,0);

if(sockfd < 0)
{
	perror("socket failed\n");
	exit(EXIT_FAILURE);
}

struct sockaddr_in serveraddr;

serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(atoi(argv[1]));
serveraddr.sin_addr.s_addr = INADDR_ANY;

if(bind(sockfd,(struct sockaddr*)&serveraddr,sizeof(serveraddr)) < 0)
{
	perror("bind failed\n");
	exit(EXIT_FAILURE);
}


if(listen(sockfd,10) < 0)
{
	perror("listen failed\n");
	exit(EXIT_FAILURE);

}

struct sockaddr_in clientaddr;
socklen_t clientaddr_len = sizeof(clientaddr);

while(1)
{

	int fd = accept(sockfd,(struct sockaddr*)&clientaddr,&clientaddr_len);
	time_t t = time(NULL);
	char* st = ctime(&t);

	//write(fd,st,strlen(st));
	size_t rsize = 0;
	size_t trsize = 0;
	while(trsize != 100*1024)
	{
		rsize = read(fd,sbuf + trsize,1024);
		trsize += rsize;
		//usleep(2000);
	}
	printf("ch is %c\n",sbuf[100*1024 -1]);


}



return 0;

}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

#include<stdio.h> #include<stdlib.h> #include<string.h> #include<unistd.h> #include<fcntl.h> #include<sys/types.h> #include<sys/stat.h> //#include"uart_tios.h"

#include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h>

int sockfd;

void sig_handler(int signo) { if(signo == SIGINT) { close(sockfd); printf("farewell\n"); exit(EXIT_FAILURE); }

}

char rbuf[128*1024] = {0};

int main(int argc,char* argv[]) {

if(argc <3)
{
	printf("%s usage:ip port\n",argv[1]);
	exit(EXIT_FAILURE);

}


if(signal(SIGINT,sig_handler) == SIG_ERR)
{
	exit(EXIT_FAILURE);
}


sockfd = socket(AF_INET,SOCK_STREAM,0);

if(sockfd < 0)
{
	perror("socket failed\n");
	exit(EXIT_FAILURE);

}

struct sockaddr_in serveraddr;
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(atoi(argv[2]));
inet_pton(AF_INET,argv[1],&serveraddr.sin_addr.s_addr);

if(connect(sockfd,(struct sockaddr*)&serveraddr,sizeof(serveraddr)) < 0)
{
	perror("connect failed\n");
	exit(EXIT_FAILURE);
}

rbuf[100*1024-1] = 'T';
write(sockfd,rbuf,100*1024);
printf("write done\n");

return 0;

}

///////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <termios.h>
#include <errno.h>
#include <getopt.h>
#include <time.h>
#include <sys/select.h>
#include "com_uart_port.h"

int setOpt(int fd, int nSpeed, int nBits, int nParity, int nStop) { struct termios newtio, oldtio;

// 保存测试现有串口参数设置，在这里如果串口号等出错，会有相关的出错信息
// get current parameters
if (tcgetattr(fd, &oldtio) != 0)
{
    perror("SetupSerial 1");
    return -1;
}

//新termios参数清零
bzero(&newtio, sizeof(newtio));   


//CLOCAL--忽略 modem 控制线,本地连线, 不具数据机控制功能, CREAD--使能接收标志
newtio.c_cflag |= CLOCAL | CREAD; 



// 设置数据位数
// 清数据位标志
newtio.c_cflag &= ~CSIZE;   

switch (nBits)
{
    case 7:
        newtio.c_cflag |= CS7;
    break;
    case 8:
        newtio.c_cflag |= CS8;
    break;
    default:
        fprintf(stderr, "Unsupported data size\n");
        return -1;
}

// 设置校验位
switch (nParity)
{
    case 'o':
    case 'O'://奇校验
        newtio.c_cflag |= PARENB;
        newtio.c_cflag |= PARODD;
        newtio.c_iflag |= (INPCK | ISTRIP);
        break;
    case 'e':
    case 'E'://偶校验
        newtio.c_iflag |= (INPCK | ISTRIP);
        newtio.c_cflag |= PARENB;
        newtio.c_cflag &= ~PARODD;
        break;
    case 'n':
    case 'N'://无校验
        newtio.c_cflag &= ~PARENB;
        break;
    default:
        fprintf(stderr, "Unsupported parity\n");
        return -1;
}

// 设置停止位
switch (nStop)
{
    case 1:
        newtio.c_cflag &= ~CSTOPB;
    break;
    case 2:
        newtio.c_cflag |= CSTOPB;
    break;
    default:
        fprintf(stderr,"Unsupported stop bits\n");
        return -1;
}


// 设置波特率 2400/4800/9600/19200/38400/57600/115200/230400
switch (nSpeed)
{
    case 2400:
        cfsetispeed(&newtio, B2400);
        cfsetospeed(&newtio, B2400);
        break;
    case 4800:
        cfsetispeed(&newtio, B4800);
        cfsetospeed(&newtio, B4800);
        break;
    case 9600:
        cfsetispeed(&newtio, B9600);
        cfsetospeed(&newtio, B9600);
        break;
    case 19200:
        cfsetispeed(&newtio, B19200);
        cfsetospeed(&newtio, B19200);
        break;
    case 38400:
        cfsetispeed(&newtio, B38400);
        cfsetospeed(&newtio, B38400);
        break;
    case 57600:
        cfsetispeed(&newtio, B57600);
        cfsetospeed(&newtio, B57600);
        break;
    case 115200:
        cfsetispeed(&newtio, B115200);
        cfsetospeed(&newtio, B115200);
        break;
    case 230400:
        cfsetispeed(&newtio, B230400);
        cfsetospeed(&newtio, B230400);
        break;
    default:
        printf("\tSorry, Unsupported baud rate, set default 9600!\n\n");
        cfsetispeed(&newtio, B9600);
        cfsetospeed(&newtio, B9600);
        break;
}



// 设置read读取最小字节数和超时时间
// 读取一个字符等待1*(1/10)s
newtio.c_cc[VTIME] = 1;


// 读取字符的最少个数为1
newtio.c_cc[VMIN] = 1; 




tcflush(fd,TCIFLUSH); //清空缓冲区

//激活新设置
if (tcsetattr(fd, TCSANOW, &newtio) != 0) 
{
    perror("SetupSerial 3");
    return -1;
}

printf("Serial set done!\n");

return 0;

}

int com_recv(int fd, char *rcv_buf, int data_len, int timeout) { int len, fs_sel; fd_set fs_read; struct timeval time;

if(timeout >=0)
{
	time.tv_sec  = timeout / 1000;       //set the rcv wait time
	time.tv_usec = timeout % 1000 * 1000;//100000us = 0.1s
}


FD_ZERO(&fs_read); //每次循环都要清空集合，否则不能检测描述符变化
FD_SET(fd, &fs_read);//添加描述符

// 超时等待读变化，>0：就绪描述字的正数目， -1：出错， 0 ：超时
if(timeout >=0)
{
	fs_sel = select(fd + 1, &fs_read, NULL, NULL, &time);
}
else
{

	fs_sel = select(fd + 1, &fs_read, NULL, NULL, NULL);

}
//    printf("fs_sel = %d\n", fs_sel);
if(fs_sel)
{
	len = read(fd, rcv_buf, data_len);
	return len;
}
else
{
	printf("Sorry,I am wrong!");
	return -1;
}

}

int com_send(int fd, char *send_buf, int data_len) { ssize_t ret = 0;

ret = write(fd, send_buf, data_len);
if (ret == data_len)
{
	//printf("send data is %s\n", send_buf);
	return ret;
}
else
{
	printf("write device error\n");
	tcflush(fd,TCOFLUSH);
	return -1;
}

}

int32_t init_com_port(enum COM_PORT port,uint32_t baudrate) { int fdSerial;

// 打开串口设备
fdSerial = open(DEV_NAME, O_RDWR | O_NOCTTY | O_NDELAY);
if(fdSerial < 0)
{
	perror(DEV_NAME);
	return -1;
}

// 设置串口阻塞， 0：阻塞， FNDELAY：非阻塞
//阻塞，即使前面在open串口设备时设置的是非阻塞的

if (fcntl(fdSerial, F_SETFL, 0) < 0)   						
{
	printf("fcntl failed!\n");
}
else
{
	printf("fcntl=%d\n", fcntl(fdSerial, F_SETFL, 0));
}

if (isatty(fdSerial) == 0)
{
	printf("standard input is not a terminal device\n");
	close(fdSerial);
	return -1;
}
else
{
	printf("is a tty success!\n");
}
printf("fd-open=%d\n", fdSerial);

// 设置串口参数
//if (setOpt(fdSerial, 115200, 8, 'N', 1)== -1)    //设置8位数据位、1位停止位、无校验
if (setOpt(fdSerial, baudrate, 8, 'N', 1)== -1)    //设置8位数据位、1位停止位、无校验
{
	fprintf(stderr, "Set opt Error\n");
	close(fdSerial);
	exit(1);
}

tcflush(fdSerial, TCIOFLUSH);    //清掉串口缓存
fcntl(fdSerial, F_SETFL, 0);    //串口阻塞


return fdSerial;
;

}

#if 0 int main (int argc, char *argv[]) {

int fdSerial = init_com_port(USER_COM0,115200);

uint8_t rcv_buf[128]={0};
uint8_t send_buf[128]={0x31,0x32,0x33,0x34,0x35,0x36,0x37,0x38,0x39,0x31,0x32,0x33,0x34,0x35,0x36,0x37};
int len;
uint32_t ch_cnt =0;

while(1)    //循环读取数据
{

	com_send(fdSerial, send_buf, 16);
	//usleep(300000);

	com_recv(fdSerial, rcv_buf, 128, 1000);

	if(rcv_buf[0] != send_buf[0]) 
	{
		perror("com data error");
		exit(EXIT_FAILURE);

	}
	else
	{
		printf("rec is %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %2x %d\n",\
				rcv_buf[0],rcv_buf[1],rcv_buf[2],rcv_buf[3],rcv_buf[4],rcv_buf[5],rcv_buf[6],rcv_buf[7],\
				rcv_buf[8],rcv_buf[9],rcv_buf[10],rcv_buf[11],rcv_buf[12],rcv_buf[13],rcv_buf[14],rcv_buf[15],++ch_cnt);
	}



	send_buf[0]++;
	rcv_buf[0]=0;

	usleep(30000);    //休眠10ms
	//sleep(1);    //休眠1s
	if(send_buf[0] > 0x39)
		break;
}


close(fdSerial);
return 0;

} #endif

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

#include<stdio.h> #include<stdlib.h> #include<string.h> #include<sys/types.h> #include<sys/stat.h> #include<unistd.h> #include<fcntl.h>

#include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h>

int sockfd;

void sig_handler(int signo) { if(signo == SIGINT) { printf("farewell server\n"); exit(EXIT_FAILURE); }

}

int main(int argc,char* argv[]) { if(argc < 2) { printf("usage: %s port",argv[0]); exit(EXIT_FAILURE);

}

if(signal(SIGINT,sig_handler) == SIG_ERR)
{
	perror("signal failed\n");
	exit(EXIT_FAILURE);
}

sockfd = socket(AF_INET,SOCK_DGRAM,0);

if(sockfd < 0)
{
	perror("socket failed\n");
	exit(EXIT_FAILURE);
}

struct sockaddr_in serveraddr;
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(atoi(argv[1]));
serveraddr.sin_addr.s_addr = INADDR_ANY;

if(bind(sockfd,(struct sockaddr*)&serveraddr,sizeof(serveraddr)) < 0)
{
	perror("bind failed\n");
	exit(EXIT_FAILURE);
}

char udp_buf[64] = {0};
struct sockaddr_in clientaddr;

socklen_t clientaddr_len;

if(recvfrom(sockfd,udp_buf,sizeof(udp_buf),0,(struct sockaddr*)&clientaddr,&clientaddr_len) < 0)
{
	perror("recvfrom failed\n");
	exit(EXIT_FAILURE);
}

printf("got message %s\n",udp_buf);

close(sockfd);
return 0;

}

///////////////////////////////////////////////////////////////////////////////////////////////////////////////

#include<stdio.h> #include<stdlib.h> #include<string.h> #include<sys/types.h> #include<sys/stat.h> #include<unistd.h> #include<fcntl.h>

#include<sys/select.h>

#include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h>

int sockfd;

void sig_handler(int signo) { if(signo == SIGINT) { printf("farewell client\n"); close(sockfd); exit(EXIT_FAILURE); }

}

int main(int argc,char* argv[]) { if(argc < 3) { printf("usage: %s ip port\n",argv[0]); }

sockfd = socket(AF_INET,SOCK_DGRAM,0);
if(sockfd < 0)
{
	perror("socket failed\n");
	exit(EXIT_FAILURE);
}

int opt =1;
if(setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt)) < 0)
{
	perror("setsockopt failed\n");
	exit(EXIT_FAILURE);
}


struct sockaddr_in serveraddr;
serveraddr.sin_family = AF_INET;
serveraddr.sin_port = htons(atoi(argv[2]));
inet_pton(AF_INET,argv[1],&serveraddr.sin_addr.s_addr);

if(connect(sockfd,(struct sockaddr*)&serveraddr,sizeof(serveraddr)) < 0)
{
	perror("connect failed\n");
	exit(EXIT_FAILURE);
}

char udp_buf[64] ="client message\n";

if(send(sockfd,udp_buf,strlen(udp_buf),0) < 0 )
{
	perror("send failed\n");
	exit(EXIT_FAILURE);
}


close(sockfd);


return 0;

}

Linux TCP server.c client.c and UDP server.c client.c - JohnHau/mis GitHub Wiki

⚠️ GitHub.com Fallback ⚠️

Linux TCP server.c client.c and UDP server.c client.c - JohnHau/mis GitHub Wiki

⚠️ **GitHub.com Fallback** ⚠️

⚠️ GitHub.com Fallback ⚠️