Linux网络编程(四) 同时处理一个端口的UDP与TCP连接

2024-05-09 19:28
文章标签 linux udp tcp 端口 编程 连接 网络 处理

本文主要是介绍Linux网络编程(四) 同时处理一个端口的UDP与TCP连接，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

从bind系统调用的参数来看，一个socket只能与一个socket地址绑定，即一个socket只能用来监听一个端口。因此，服务器如果要同时监听多个端口，就必须创建多个socket，并将它们分别绑定到各个端口上。这样一来，服务器程序就需要同时管理多个监听socket，I/O复用技术就有了用武之地。

即使是同一个端口，如果服务器要同时处理该端口上的TCP和UDP请求，则也需要创建两个不同的socket：一个是流socket，另一个是数据报socket，并将它们都绑定到该端口上。

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/epoll.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <fcntl.h>
#include <stdlib.h>#define MAX_EVENT_NUMBER 1024
#define TCP_BUFFER_SIZE 512
#define UDP_BUFFER_SIZE 1024/* 设置文件为非阻塞 */
int setnonblocking(int fd)
{int old_option = fcntl(fd, F_GETFL);int new_option = old_option | O_NONBLOCK;fcntl(fd, F_SETFL, new_option);return old_option;
}/* 添加epoll事件，ET边缘触发模式 */
void addfd(int epollfd, int fd)
{struct epoll_event event;event.data.fd = fd;event.events = EPOLLIN | EPOLLET;epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &event);setnonblocking(fd);
}int main()
{const char *ip = "127.0.0.1";int port = 8080;int ret = 0;struct sockaddr_in address;bzero(&address, sizeof(address));address.sin_family = AF_INET;inet_pton(AF_INET, ip, &address.sin_addr);address.sin_port = htons(port);/*创建TCP socket，并将其绑定到端口port上*/int tcpfd = socket(PF_INET, SOCK_STREAM, 0);ret = bind(tcpfd, (struct sockaddr *)&address, sizeof(address));assert(ret != -1);ret = listen(tcpfd, 5);assert(ret != -1);/*创建UDP socket，并将其绑定到端口port上*/bzero(&address, sizeof(address));address.sin_family = AF_INET;inet_pton(AF_INET, ip, &address.sin_addr);address.sin_port = htons(port);int udpfd = socket(PF_INET, SOCK_DGRAM, 0);ret = bind(udpfd, (struct sockaddr *)&address, sizeof(address));assert(ret != -1);/* 创建epoll事件表 */struct epoll_event events[MAX_EVENT_NUMBER];int epollfd = epoll_create(256);assert(epollfd != -1);/* 注册TCP socket和UDP socket上的可读事件 */addfd(epollfd, tcpfd);addfd(epollfd, udpfd);while (1){int number = epoll_wait(epollfd, events, MAX_EVENT_NUMBER, -1);if (number < 0){printf("epoll failure\n");break;}// 处理事件for (int i = 0; i < number; i++){int sockfd = events[i].data.fd;// 如果是tcp连接事件，那么将其注册到epoll事件表中if (sockfd == tcpfd){struct sockaddr_in client_address;socklen_t client_addrlength = sizeof(client_address);int connfd = accept(tcpfd, (struct sockaddr *)&client_address, &client_addrlength);addfd(epollfd, connfd);}// 如果是udp连接事件，那么else if (sockfd == udpfd){char buf[UDP_BUFFER_SIZE];memset(buf, '\0', UDP_BUFFER_SIZE);struct sockaddr_in client_address;socklen_t client_addrlength = sizeof(client_address);// 将udp中的数据读取到buf中ret = recvfrom(udpfd, buf, UDP_BUFFER_SIZE - 1, 0,(struct sockaddr *)&client_address, &client_addrlength);// 如果收到了数据,打印if (ret > 0){printf("%s\n",buf);}}// 如果是一个socket有数据输入else if (events[i].events & EPOLLIN){char buf[TCP_BUFFER_SIZE];while (1){memset(buf, '\0', TCP_BUFFER_SIZE);ret = recv(sockfd, buf, TCP_BUFFER_SIZE - 1, 0);if (ret < 0){   // 如果当前操作非阻塞，操作无法立即完成，那么先不做处理if ((errno == EAGAIN) || (errno == EWOULDBLOCK)) break;// 如果是出现了其他错误，那么关闭socketclose(sockfd);break;}// 如果数据已经读完else if (ret == 0){close(sockfd);}// 如果是其他情况，那么返回收到的数据else{printf("%s\n",buf);}}}else{printf("something else happened\n");}}}close(tcpfd);return 0;
}

主要的精髓在这里

int tcpfd = socket(PF_INET, SOCK_STREAM, 0);
int udpfd = socket(PF_INET, SOCK_DGRAM, 0);

看一下客户端：

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  
#include <arpa/inet.h>  
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  #define SERVER_IP "127.0.0.1"  
#define SERVER_PORT 8080  
#define BUFFER_SIZE 1024  int main() {  int tcp_socket, udp_socket;  struct sockaddr_in server_addr;  char buffer[BUFFER_SIZE];  ssize_t bytes_sent;  // 创建TCP socket  tcp_socket = socket(AF_INET, SOCK_STREAM, 0);  if (tcp_socket == -1) {  perror("TCP socket creation failed");  exit(EXIT_FAILURE);  }  // 创建UDP socket  udp_socket = socket(AF_INET, SOCK_DGRAM, 0); if (udp_socket == -1) {  perror("UDP socket creation failed");  exit(EXIT_FAILURE);  }  // 设置服务器地址信息  memset(&server_addr, 0, sizeof(server_addr));  server_addr.sin_family = AF_INET;  server_addr.sin_port = htons(SERVER_PORT);  if (inet_pton(AF_INET, SERVER_IP, &server_addr.sin_addr) <= 0) {  perror("Invalid server address");  close(tcp_socket);  close(udp_socket);  exit(EXIT_FAILURE);  }   // 连接到TCP服务器  if (connect(tcp_socket, (struct sockaddr *) &server_addr, sizeof(server_addr)) == -1) {  perror("TCP connection failed");  close(tcp_socket);  close(udp_socket);  exit(EXIT_FAILURE);  }  printf("Connected to server\n");  // 发送TCP消息给服务器  const char *tcp_message = "Hello, this is TCP message!\n";bytes_sent = send(tcp_socket, tcp_message, strlen(tcp_message), 0);  if (bytes_sent == -1) {perror("TCP send failed");close(tcp_socket);close(udp_socket);exit(EXIT_FAILURE);}// 发送UDP消息给服务器  const char *udp_message = "Hello, this is UDP message!\n";bytes_sent = sendto(udp_socket, udp_message, strlen(udp_message), 0, (struct sockaddr *) &server_addr, sizeof(server_addr));if (bytes_sent == -1) {perror("UDP sendto failed");close(tcp_socket);close(udp_socket);exit(EXIT_FAILURE);}// 关闭连接close(tcp_socket);close(udp_socket);return 0;
}

仿真

image-20240507214628171

这篇关于Linux网络编程(四) 同时处理一个端口的UDP与TCP连接的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/974283。

相关文章

java并发编程之CyclicBarrier（循环栅栏）

java并发编程之CyclicBarrier（循环栅栏）

package com.zhong;import java.util.concurrent.CyclicBarrier;/*** Cyclic意思是循环，Barrier意思是屏障，那么CyclicBarrier翻译过来就是循环栅栏。* 它是一个同步辅助类，能让一组线程互相等待，* 直到这一组线程都到了一个公共屏障点，各线程才能继续向下执行。因为该屏障能够在释放等待线程后继续重用，所以叫循环屏障。*
阅读更多...
java后台DecimalFormat处理数字，3位加逗号分隔

java后台DecimalFormat处理数字，3位加逗号分隔

package com.zhong;import java.math.BigDecimal;import java.text.DecimalFormat;/*** 给数字每三位加一个逗号工具类* @author admin**/public class DecimalFormatUtil {public static final String DEFAULT_FORMAT = "#,###.
阅读更多...
springMVC处理请求过程

springMVC处理请求过程

一、 步骤图 二、主要步骤  1、用户发送请求至前端控制器DispatcherServlet。 2、DispatcherServlet收到请求调用HandlerMapping处理器映射器。 3、处理器映射器找到具体的处理器(可以根据xml配置、注解进行查找)，生成处理器对象及处理器拦截器(如果有则生成)一并返回给DispatcherServlet。 4、 DispatcherServ
阅读更多...
MyBatis的update语句的返回值改为从匹配数改为受影响的记录数，向mysql连接添加useAffectedRows=true一个参数即可。

MyBatis的update语句的返回值改为从匹配数改为受影响的记录数，向mysql连接添加useAffectedRows=true一个参数即可。

1、现象mysql更新update语句执行时，没有内容变更的话，会返回“0”；存在内容更新的话，会返回会返回有内容更新的记录数“1”。  2、mybatis默认情况，没有内容更新也是返回“1”。这么怎么会是”1“，不应该是”0“？？？其实默认mybatis返回的是 Rows matched “1”，而不是 “ 0 row affected ”中的 “0”。  3、那需要怎么才能让m
阅读更多...
Linux命令学习之二

Linux命令学习之二

每日一结 ​               命令置换：是将一个命令的输出作为另一个命令的参数，命令格式如下： commond1 `command2` 其中，命令command2的输出将作为命令command1的参数，需要注意的是， 命令置换的单引号为ESC键下方的 ` 其意思就是说，先运行单引号内的命令，再将其命令作为
阅读更多...
Linux命令学习之一

Linux命令学习之一

每日一结                                                                                        注：当用户不确定一个软件包的类型时， 可使用file命令查看文件类型
阅读更多...
Linux文件I/O之一

Linux文件I/O之一

每日一结(标准I/O)   一  库    本质 :一组实现函数接口 [printf,scanf,strcpy,strlen]   使用标准库好处:屏蔽底层细节，向上层提供统一的接口,提高程序的可移植性   windows 库 : *.dll  linux   库 : *.so    二 系统调用接口    本
阅读更多...
嵌入式C和汇编混合编程规则——ATPCS规则

嵌入式C和汇编混合编程规则——ATPCS规则

ATPCS规则  为了使单独编译的C语言程序和汇编程序之间能够相互调用,必须为子程序之间的调用规定一定的规则.ATPCS就是ARM程序和THUMB程序中子程序调用的基本规则。 一.ATPCS概述 ATPCS规定了一些子程序之间调用的基本规则.这些基本规则包括子程序调用过程中寄存器的使用规则,数据栈的使用规则,参数的传递规则.为适应一些特定的需要,对这些基本的调用规则进行一些修改得到几种不
阅读更多...
Linux网络编程之五

Linux网络编程之五

每日一结 组播： ​ 网络地址： 一些特殊的组播地址：   一 组播包收和发 1.发送方 (1)创建用户数据报套接字 (2)填充组播地址和端口  (3)发送数据到组播地址 2.接收方  (1)创建用户数据报套接字 (2)加入组播组  struct ip_mreq mreq; mreq.imr_m
阅读更多...
Linux网络编程之四

Linux网络编程之四

每日一结 一 UDP并发  核心思想:父进程接收到客户端的数据，就创建子进程，在子进程中创建一个新的套接字  和客户端交互  int do_client(接受客户端地址，数据，数据长度) { 1.创建用户数据报套接字  2.自动分配地址  3.处理数据[例如:输出数据内容] 4.通过新创建的套接字将数据回发给客户端  w
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2