bsd协议开源框架tcp服务器,搬运RT Thread中BSD Socket实现UDP及TCP例子
/*
* Copyright (c) 2006-2018, RT-Thread Development Team
*
* SPDX-License-Identifier: Apache-2.0
*
* Change Logs:
* Date Author Notes
*
*/
/*
* 程序清单:tcp 服务端
*
* 这是一个 tcp 服务端的例程
* 导出 tcpserv 命令到控制终端
* 命令调用格式:tcpserv
* 无参数
* 程序功能:作为一个服务端,接收并显示客户端发来的数据 ,接收到 exit 退出程序
*/
#include
#include
/* 使用BSD socket,需要包含socket.h头文件 */
#include
#include
#include
#define BUFSZ (1024)
static const char send_data[] = "This is TCP Server from RT-Thread.";
/* 发送用到的数据 */
static void tcpserv(int argc, char **argv)
{
char *recv_data;
/* 用于接收的指针,后面会做一次动态分配以请求可用内存 */
socklen_t sin_size;
int sock, connected, bytes_received;
struct sockaddr_in server_addr, client_addr;
rt_bool_t stop = RT_FALSE;
/* 停止标志 */
int ret;
recv_data = rt_malloc(BUFSZ + 1);
/* 分配接收用的数据缓冲 */
if (recv_data == RT_NULL)
{
rt_kprintf("No memory\n");
return;
}
/* 一个socket在使用前,需要预先创建出来,指定SOCK_STREAM为TCP的socket */
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
/* 创建失败的错误处理 */
rt_kprintf("Socket error\n");
/* 释放已分配的接收缓冲 */
rt_free(recv_data);
return;
}
/* 初始化服务端地址 */
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(5000);
/* 服务端工作的端口 */
server_addr.sin_addr.s_addr = INADDR_ANY;
rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
/* 绑定socket到服务端地址 */
if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
{
/* 绑定失败 */
rt_kprintf("Unable to bind\n");
/* 释放已分配的接收缓冲 */
rt_free(recv_data);
return;
}
/* 在socket上进行监听 */
if (listen(sock, 5) == -1)
{
rt_kprintf("Listen error\n");
/* release recv buffer */
rt_free(recv_data);
return;
}
rt_kprintf("\nTCPServer Waiting for client on port 5000...\n");
while (stop != RT_TRUE)
{
sin_size = sizeof(struct sockaddr_in);
/* 接受一个客户端连接socket的请求,这个函数调用是阻塞式的 */
connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
/* 返回的是连接成功的socket */
if (connected < 0)
{
rt_kprintf("accept connection failed! errno = %d\n", errno);
continue;
}
/* 接受返回的client_addr指向了客户端的地址信息 */
rt_kprintf("I got a connection from (%s , %d)\n",
inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
/* 客户端连接的处理 */
while (1)
{
/* 发送数据到connected socket */
ret = send(connected, send_data, strlen(send_data), 0);
if (ret < 0)
{
/* 发送失败,关闭这个连接 */
closesocket(connected);
rt_kprintf("\nsend error,close the socket.\r\n");
break;
}
else if (ret == 0)
{
/* 打印send函数返回值为0的警告信息 */
rt_kprintf("\n Send warning,send function return 0.\r\n");
}
/* 从connected socket中接收数据,接收buffer是1024大小,但并不一定能够收到1024大小的数据 */
bytes_received = recv(connected, recv_data, BUFSZ, 0);
if (bytes_received < 0)
{
/* 接收失败,关闭这个connected socket */
closesocket(connected);
break;
}
else if (bytes_received == 0)
{
/* 打印recv函数返回值为0的警告信息 */
rt_kprintf("\nReceived warning,recv function return 0.\r\n");
closesocket(connected);
break;
}
/* 有接收到数据,把末端清零 */
recv_data[bytes_received] = '\0';
if (strcmp(recv_data, "q") == 0 || strcmp(recv_data, "Q") == 0)
{
/* 如果是首字母是q或Q,关闭这个连接 */
closesocket(connected);
break;
}
else if (strcmp(recv_data, "exit") == 0)
{
/* 如果接收的是exit,则关闭整个服务端 */
closesocket(connected);
stop = RT_TRUE;
break;
}
else
{
/* 在控制终端显示收到的数据 */
rt_kprintf("RECEIVED DATA = %s \n", recv_data);
}
}
} /* 退出服务 */
closesocket(sock);
/* 释放接收缓冲 */
rt_free(recv_data);
return ;
}
MSH_CMD_EXPORT(tcpserv, a tcp server sample);
bsd协议开源框架tcp服务器,搬运RT Thread中BSD Socket实现UDP及TCP例子相关推荐
- c# mqtt高性能服务器端源代码 开源框架包括服务器和客户端,支持mqtt3.0及5.0
c# mqtt高性能服务器端源代码. 你还在使用第三方服务软件吗?不如试试这个开发框架,助你一臂之力,无限制,无全开源,无版权约束,全是自主开发. 开源框架包括服务器和客户端,支持mqtt3.0及5. ...
- [腾讯社区开放平台].NET SDK基于New BSD协议开源
"QQ登录"使用户能使用QQ账号一键登录接入网站,大大降低了注册.登录的门槛.借助庞大的QQ用户群,给第三方网站带来更多新用户.已登录用户还可以将在第三方网站发布.分享的信息即时同 ...
- 网络协议从入门到底层原理(5)传输层(UDP、TCP - 可靠传输、流量控制、拥塞控制、建立连接、释放连接)
传输层( Transport) 传输层( Transport) UDP 协议(数据格式.检验和) 端口(Port) TCP TCP - 数据偏移.保留 TCP - 检验和( CheckSum) TCP ...
- TCP服务器和客户端的创建(socket/socketserver)
1 本文记录针对python网络编程学习过程中的socket部分进行记录与总结,内容仅仅涉及最粗浅的部分,日后或许会进行更新与扩展. 2 本文涉及的socket数据传输均使用bytes类型,因此在py ...
- 基于Socket的UDP和TCP编程介绍
一.概述 TCP(传输控制协议)和UDP(用户数据报协议是网络体系结构TCP/IP模型中传输层一层中的两个不同的通信协议. TCP:传输控制协议,一种面向连接的协议,给用户进程提供可靠的全双工的字节流 ...
- 基于Socket的UDP和TCP编程介绍-转
一.概述 TCP(传输控制协议)和UDP(用户数据报协议是网络体系结构TCP/IP模型中传输层一层中的两个不同的通信协议. TCP:传输控制协议,一种面向连接的协议,给用户进程提供可靠的全双工的字节流 ...
- linux tcp连接计算机,计算机基础知识——linux socket套接字tcp连接分析
2016.7.4 今天晚上对项目顶层文件(daemon)进行了分析,对其中的TCP连接进行具体的代码级分析. 1.需求分析 首先得知道我们这里为什么要用TCP连接,我们的整个测试系统是由上位机作为客户 ...
- tcp服务器制作,用telnet来测试你自己写的TCP服务器
有时候我们写一个tcp的服务器程序,需要让客户端发起一个连接,来验证是否能正确的 绑定到端口 接受连接 接受数据 通常我们需要写一个客户端,但是如果你用telnet的话,那就不用为了上面的这个目的而写 ...
- java建立tcp服务器长连接_B/S 架构下后端能否建立 TCP 长连接?
这种架构下,这样的优化策略能实现吗?能有作用吗? php 服务端请求 ES tcp server 部分代码 $streamClient = stream_socket_client("tcp ...
最新文章
- 雨量、阳光、防雾传感器
- 如何正确解码用户的“玄学需求”?
- 效能改进之项目例会导入实践
- 为什么VS(visual studio)中会建议宏 #define 转换为constexpr?
- .NET中扩展方法和Enumerable(System.Linq)
- linux中的集线器、交换机、路由器及组网
- ubuntu下安装jdk
- linux设置windows共享为yum源
- 【转】新.Net开发必备工具详解之Snippet Compiler。
- mysql timestamp 当前_技术分享 | MySQL 复制那点事 - Seconds_behind_Master 参数调查笔记
- java中复制图片_2017.5.3 java中 复制图片的4种方式(copy图片只能用字节流对象)...
- js 去除空格与换行
- 读书项目:ePub标准介绍
- channel使用法则
- 计算机应用参考文献,计算机应用领域英文参考文献 哪里有计算机应用领域参考文献...
- Woodbury矩阵恒等式介绍
- 支持响应式手机端jQuery图片轮播插件unslider
- 版式设计:什么是“三率一界”?
- 【面试大全-网络】网络的点点滴滴
- 流媒体封装格式和流媒体传输协议介绍
热门文章
- 为屏而生,为屏而死 - IT 精英”们的杯与具
- oracle win 7 64 下载,oracle 安装 win7 64_win732位系统下载 - Win7之家
- js日历插件 中文、英文日历
- 东软移动互联网事业部SMIAS短信网关系统
- 20190415每周精品之淘宝
- C#WinForm多行文本框
- (C语言)八大排序之:归并排序
- 计算机管理打开报mmc.exe,Win10打开软件提示“管理员已阻止你运行此应用mmc.exe”解决方法...
- 2021年高项案例分析题真题及答案解析(5月和11月考试)
- java猫和老鼠_猫抓老鼠-Java面向对象特点梳理