From 082a7727fcd8298ed360c40670ca34054c972733 Mon Sep 17 00:00:00 2001
From: adminPyf <3043130461@qq.com>
Date: Mon, 14 Jun 2021 00:21:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=96=87=E4=BB=B6=E8=87=B3?=
=?UTF-8?q?=20'test=5Fbuffer=5Fclient'?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
bufferevent Demo
---
test_buffer_client/first_libevent.vcxproj | 162 +++++++++++++
.../first_libevent.vcxproj.user | 4 +
test_buffer_client/makefile | 2 +
test_buffer_client/test_buffer_client.cpp | 218 ++++++++++++++++++
test_buffer_client/test_buffer_client.sln | 31 +++
5 files changed, 417 insertions(+)
create mode 100644 test_buffer_client/first_libevent.vcxproj
create mode 100644 test_buffer_client/first_libevent.vcxproj.user
create mode 100644 test_buffer_client/makefile
create mode 100644 test_buffer_client/test_buffer_client.cpp
create mode 100644 test_buffer_client/test_buffer_client.sln
diff --git a/test_buffer_client/first_libevent.vcxproj b/test_buffer_client/first_libevent.vcxproj
new file mode 100644
index 0000000..3325add
--- /dev/null
+++ b/test_buffer_client/first_libevent.vcxproj
@@ -0,0 +1,162 @@
+
+
+
+
+ Debug
+ Win32
+
+
+ Release
+ Win32
+
+
+ Debug
+ x64
+
+
+ Release
+ x64
+
+
+
+ 15.0
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}
+ Win32Proj
+ firstlibevent
+ 10.0.17763.0
+ test_buffer_client
+
+
+
+ Application
+ true
+ v141
+ Unicode
+
+
+ Application
+ false
+ v141
+ true
+ Unicode
+
+
+ Application
+ true
+ v141
+ Unicode
+
+
+ Application
+ false
+ v141
+ true
+ Unicode
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ true
+
+
+ true
+
+
+ false
+
+
+ false
+
+
+
+
+
+ Level3
+ Disabled
+ true
+ WIN32;_DEBUG;_CONSOLE;%(PreprocessorDefinitions)
+ true
+
+
+ Console
+ true
+
+
+
+
+ NotUsing
+ Level3
+ Disabled
+ true
+ _DEBUG;_CONSOLE;%(PreprocessorDefinitions);_CRT_SECURE_NO_WARNINGS
+ true
+ ..\..\include
+
+
+ Console
+ true
+ ..\..\lib
+ libevent.lib;ws2_32.lib;%(AdditionalDependencies)
+
+
+
+
+
+
+ Level3
+ MaxSpeed
+ true
+ true
+ true
+ WIN32;NDEBUG;_CONSOLE;%(PreprocessorDefinitions)
+ true
+
+
+ Console
+ true
+ true
+ true
+
+
+
+
+
+
+ Level3
+ MaxSpeed
+ true
+ true
+ true
+ NDEBUG;_CONSOLE;%(PreprocessorDefinitions)
+ true
+
+
+ Console
+ true
+ true
+ true
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/test_buffer_client/first_libevent.vcxproj.user b/test_buffer_client/first_libevent.vcxproj.user
new file mode 100644
index 0000000..6e2aec7
--- /dev/null
+++ b/test_buffer_client/first_libevent.vcxproj.user
@@ -0,0 +1,4 @@
+
+
+
+
\ No newline at end of file
diff --git a/test_buffer_client/makefile b/test_buffer_client/makefile
new file mode 100644
index 0000000..2a401bf
--- /dev/null
+++ b/test_buffer_client/makefile
@@ -0,0 +1,2 @@
+test_buffer_client:test_buffer_client.cpp
+ g++ $^ -o $@ -levent
\ No newline at end of file
diff --git a/test_buffer_client/test_buffer_client.cpp b/test_buffer_client/test_buffer_client.cpp
new file mode 100644
index 0000000..91dc6bd
--- /dev/null
+++ b/test_buffer_client/test_buffer_client.cpp
@@ -0,0 +1,218 @@
+#include
+#include
+#include
+#include
+#include
+
+
+#ifdef _WIN32
+#include
+#else
+#include
+#include
+#endif // !_WIN32
+
+using namespace std;
+
+static string recvstr = "";
+static int recvCount = 0;
+static int sendCount = 0;
+
+void read_cb(bufferevent * bev, void *arg) {
+ cout << "[R]" << endl;
+
+ char data[1024] = { 0 };
+ int len = bufferevent_read(bev, data, sizeof(data) - 1);
+ if (len <= 0)return;
+ recvstr += data;
+ recvCount += len;
+
+ /* if(strstr(data,"quit")!= NULL){
+ cout << "quit" << endl;
+ bufferevent_free(bev); // BEV_OPT_CLOSE_ON_FREE 设置了这个才会关闭
+ } */
+ //发送数据 写入到输出缓冲
+ bufferevent_write(bev, "ok", 3);
+}
+
+void write_cb(bufferevent * bev, void *arg) {
+ cout << "[W]" << endl;
+}
+
+//错误 超时 连接断开会进入
+void event_cb(struct bufferevent *bev, short what, void *ctx) {
+ cout << "[CB]" << endl;
+
+ //读取超时事件发生后，数据读取停止
+ if (what & BEV_EVENT_TIMEOUT && what & BEV_EVENT_READING) {
+ char data[1024] = { 0 };
+ int len = bufferevent_read(bev, data, sizeof(data) - 1);
+ if (len > 0) {
+ recvCount += len;
+ recvstr += data;
+ }
+ cout << "read timeout " << endl;
+
+ //bufferevent_enable(bev,EV_READ); //可以重新设置
+ bufferevent_free(bev);
+ cout << recvstr << endl;
+ cout << "recvCOunt" << recvCount << " sendCount" << sendCount << endl;
+
+ }
+ else if (what & BEV_EVENT_ERROR) {
+ bufferevent_free(bev);
+ }
+ else {
+ cout << "other " << endl;
+ }
+}
+
+void listen_cb(struct evconnlistener *ev, evutil_socket_t s,
+ struct sockaddr *insin, int socklen, void *arg)
+{
+ cout << "listen_cb" << endl;
+
+ struct sockaddr_in *sin = (struct sockaddr_in *)&insin;
+ int port = ntohs(sin->sin_port);
+
+ char ip[16] = { 0 };
+ evutil_inet_ntop(AF_INET, &sin->sin_addr, ip, sizeof(ip) - 1);
+ cout << "client ip is " << ip << "port is " << port << endl;
+
+
+ event_base* base = (event_base*)arg;
+ //创建bufferevent上下文 BEV_OPT_CLOSE_ON_FREE清理bufferevent时关闭socket
+ bufferevent * bev = bufferevent_socket_new(base, s, BEV_OPT_CLOSE_ON_FREE);
+ bufferevent_enable(bev, EV_READ | EV_WRITE);
+
+ //设置水位
+ //读取水位
+ bufferevent_setwatermark(bev, EV_READ,
+ 10, //低水位0就是无限制 默认0 有10个数据才会回调函数被调用
+ 10); //高水位0就是无限制 默认0 超过10的数据会拆分成多个10调用多次
+
+ bufferevent_setwatermark(bev, EV_WRITE,
+ 5, // 低水位0就是无限制 默认0 缓冲数据低于5 写入回调内调用
+ 0); //暂时无效
+
+ timeval t1 = { 0,50000 };
+ bufferevent_set_timeouts(bev, &t1, NULL);
+ bufferevent_setcb(bev, read_cb, write_cb, event_cb, base);
+}
+
+void clinet_read_cb(bufferevent * bev, void *arg) {
+ cout << "[clinet R]" << endl;
+ char data[1024] = { 0 };
+ int len = bufferevent_read(bev, data, sizeof(data) - 1);
+ if (len <= 0)return;
+ cout << "[" << data << "]" << endl;
+ /* if(strstr(data,"quit")!= NULL){
+ cout << "quit" << endl;
+ bufferevent_free(bev); // BEV_OPT_CLOSE_ON_FREE 设置了这个才会关闭
+ } */
+ //发送数据 写入到输出缓冲
+ //bufferevent_write(bev,"ok",3);
+}
+
+void clinet_write_cb(bufferevent * bev, void *arg) {
+ cout << "[clinet W]" << endl;
+ //激活write
+ FILE *fp = (FILE *)arg;
+ char data[1024] = { 0 };
+ int len = fread(data, 1, sizeof(data) - 1, fp);
+ if (len <= 0) {
+ // 读到文件结尾或者文件出错
+ fclose(fp);
+ //立刻清理 可能会造成缓冲数据没有发送结束 ！！ 不能在这里做
+ //bufferevent_free(bev);
+ bufferevent_disable(bev, EV_WRITE);
+ return;
+ }
+ sendCount += len;
+ bufferevent_write(bev, data, len);
+
+}
+
+//错误 超时 连接断开会进入
+void clinet_event_cb(struct bufferevent *bev, short what, void *ctx) {
+ cout << "[ clinet CB]" << endl;
+
+ //读取超时事件发生后，数据读取停止
+ if (what & BEV_EVENT_TIMEOUT && what & BEV_EVENT_READING) {
+ cout << "read timeout " << endl;
+
+ //bufferevent_enable(bev,EV_READ); //可以重新设置
+ bufferevent_free(bev);
+ return;
+
+ }
+ else if (what & BEV_EVENT_ERROR) {
+ bufferevent_free(bev);
+ return;
+ }
+
+ //服务端的关闭事件
+ if (what & BEV_EVENT_EOF) {
+ cout << "BEV_EVENT_EOF" << endl;
+ bufferevent_free(bev);
+ }
+
+ if (what & BEV_EVENT_CONNECTED) {
+ cout << "BEV_EVENT_CONNECTED " << endl;
+ bufferevent_trigger(bev, EV_WRITE, 0); //触发写事件
+ }
+}
+
+int main(int agrc, char **agrv)
+{
+
+#ifdef _WIN32
+ //初始化socket库
+ WSADATA wsa;
+ WSAStartup(MAKEWORD(2, 2), &wsa);
+#else
+ if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
+ { //忽略管道信号，发送数据给已关闭的socket，会飞掉！
+ return 1;
+ }
+#endif
+
+ //创建网络服务器
+ event_base *base = event_base_new();
+ sockaddr_in sin;
+ memset(&sin, 0, sizeof(sin));
+ sin.sin_family = AF_INET;
+ sin.sin_port = htons(5001);
+
+ evconnlistener_new_bind(base,
+ listen_cb,
+ base, LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
+ 10,
+ (sockaddr *)&sin,
+ sizeof(sin));
+
+ { //防止变量名重定义
+ //调用客户端代码
+ // -1 内部创建socket
+ bufferevent * bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE);
+ sockaddr_in sin;
+ memset(&sin, 0, sizeof(sin));
+ sin.sin_family = AF_INET;
+ sin.sin_port = htons(5001);
+ evutil_inet_pton(AF_INET, "127.0.0.1", &sin.sin_addr.s_addr);
+
+ FILE *fp = fopen("test_buffer_client.cpp", "rb");
+ //设置回调函数
+ bufferevent_setcb(bev, clinet_read_cb, clinet_write_cb, clinet_event_cb, fp);
+ bufferevent_enable(bev, EV_READ | EV_WRITE);
+ int ret = bufferevent_socket_connect(bev, (sockaddr*)&sin, sizeof(sin));
+ if (ret == 0) {
+ cout << "connected" << endl;
+ }
+ }
+ //进入事件主循环
+ event_base_dispatch(base);
+ event_base_free(base);
+
+ return 0;
+}
\ No newline at end of file
diff --git a/test_buffer_client/test_buffer_client.sln b/test_buffer_client/test_buffer_client.sln
new file mode 100644
index 0000000..5111269
--- /dev/null
+++ b/test_buffer_client/test_buffer_client.sln
@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 15
+VisualStudioVersion = 15.0.28307.1525
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "first_libevent", "first_libevent.vcxproj", "{129BF326-BFEE-4F1C-920C-0C302BB84895}"
+EndProject
+Global
+ GlobalSection(SolutionConfigurationPlatforms) = preSolution
+ Debug|x64 = Debug|x64
+ Debug|x86 = Debug|x86
+ Release|x64 = Release|x64
+ Release|x86 = Release|x86
+ EndGlobalSection
+ GlobalSection(ProjectConfigurationPlatforms) = postSolution
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Debug|x64.ActiveCfg = Debug|x64
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Debug|x64.Build.0 = Debug|x64
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Debug|x86.ActiveCfg = Debug|Win32
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Debug|x86.Build.0 = Debug|Win32
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Release|x64.ActiveCfg = Release|x64
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Release|x64.Build.0 = Release|x64
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Release|x86.ActiveCfg = Release|Win32
+ {129BF326-BFEE-4F1C-920C-0C302BB84895}.Release|x86.Build.0 = Release|Win32
+ EndGlobalSection
+ GlobalSection(SolutionProperties) = preSolution
+ HideSolutionNode = FALSE
+ EndGlobalSection
+ GlobalSection(ExtensibilityGlobals) = postSolution
+ SolutionGuid = {191D7F93-7554-493B-92E1-BB302C5A8383}
+ EndGlobalSection
+EndGlobal