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 ...
最新文章
- 搭建基于asp.net的wcf服务,ios客户端调用的实现记录
- java servlet上传centos服务器
- 1、Tensorflow 之 saver与checkpoint
- 微服务+异步工作流+ Serverless,Netflix 决定弃用稳定运行 7 年的旧平台
- [ZT]CCNA课堂精简笔记 2
- python安装详细步骤windows10_Windows10系统安装Python教程
- Django中文文档-The Django Book
- python题目练习001--A+B Problem
- Java基础回顾--jav集合1 集合的分类、解析
- 微信小程序 提示 provisional headers are shown
- 身份证真伪的验证(C# / ASP.NET /JS代码)及算法说明
- Codeforces Round #685 (Div. 2) (D(博弈) E1 E2(交互))
- Chrome 插件下载网站+6个实用插件推荐
- Jzoj5603 xiz
- 因融资失败倒闭 五分钟倒在黎明前五分钟
- 猿创征文|我的Go成长之路道阻且长
- 大学计算机D(VB.NET)
- IDEA中如何正确快速打jar包(包括瘦包、胖包)
- 怎么划分领域、子域、核心域、通用域和支撑域
- 房地产企业城市置业 BI 实施分析
热门文章
- 各种模拟仿真系统收集汇总(不断更新.....)
- python总结(五):函数式编程plus
- Keka for Mac(压缩解压工具)
- Arduino三轮全向小车(一):编码马达的使用
- 西北工业大学计算机考研真题百度云,2021西北工业大学考研历年真题
- vgh电压高了有什么_液晶屏VGH,VGL,VCOM电压值正常为多少-液晶屏vgh电压
- LPC 使用usb Vcom和linux主机进行通信收到乱码
- 汇编语言-第三版-王爽-第15章 外中断-第16章 直接定址表
- 开机使用脚本批处理打开软件
- conda安装gpu版tensorflow和局部cuda插件,不用配置全局cuda了