client.cpp

// App02.cpp : 定义控制台应用程序的入口点。

//

#include <string.h>

#include <errno.h>

#include <stdio.h>

#include <signal.h>

#include <iostream>

#include <thread>

#include <atomic>

#ifndef WIN32

#include <netinet/in.h>

# ifdef _XOPEN_SOURCE_EXTENDED

#  include <arpa/inet.h>

# endif

#include <sys/socket.h>

#endif

#include <event2/thread.h>

#include <event2/bufferevent.h>

#include <event2/buffer.h>

#include <event2/listener.h>

#include <event2/util.h>

#include <event2/event.h>

#include <event2/bufferevent_struct.h>

std::atomic_bool write_over;

void eventcb(struct bufferevent *bev, short events, void *ptr)

{

    if (events & BEV_EVENT_CONNECTED)

    {

         /* We're connected to 127.0.0.1:8080.   Ordinarily we'd do

            something here, like start reading or writing. */

    }

    else if (events & BEV_EVENT_ERROR)

    {

         /* An error occured while connecting. */

    }

}

//接收Server来的消息

static void conn_readcb(struct bufferevent *bev, void *user_data)//arg1:发生了事件的bufferevent，最后一个是用户提供的参数，可以通过这个向回调传递参数

{

    char buf[] = {};

    int len = bufferevent_read(bev, buf, sizeof(buf));

    std::cout<<"来自Server:"<< buf << std::endl;

}

static void conn_writecb(struct bufferevent *bev, void *user_data)

{

    write_over = true;

    //int ret = bufferevent_write(bev, "我是一个客户端！", 20);

}

struct event_base *g_base;//管理事件

int main()

{

    write_over = false;

    struct bufferevent *bev;

    struct sockaddr_in sin;

#ifdef WIN32

    WSADATA wsa_data;

    WSAStartup(0x0201, &wsa_data);

#endif

    //event支持多线程的初始化函数

    if(- == evthread_use_windows_threads())

        return false;

    g_base = event_base_new();

    memset(&sin, , sizeof(sin));

    sin.sin_family = AF_INET;

    sin.sin_addr.s_addr = htonl(0x7f000001); /* 127.0.0.1 */

    sin.sin_port = htons(); /* Port 9527 */

    bev = bufferevent_socket_new(g_base, -, BEV_OPT_CLOSE_ON_FREE | BEV_OPT_THREADSAFE);//创建基于套接字的bufferevent

 //   bufferevent_setcb(bev, NULL, NULL, eventcb, NULL);

    if (bufferevent_socket_connect(bev,//connect套接字

        (struct sockaddr *)&sin, sizeof(sin)) < )

    {

        /* Error starting connection */

        std::cout<<"连接失败！\n";

        bufferevent_free(bev);

        return -;

    }

    bufferevent_setcb(bev, conn_readcb, /*conn_writecb*/nullptr, eventcb, "回调参数");//修改回调

    bufferevent_enable(bev, EV_READ | EV_WRITE );

    std::thread th([]

    {

        event_base_dispatch(g_base);//循环处理事件

    });

    int ret = bufferevent_write(bev, "我是客户端-1", );

    std::cout<<"输入你想发送的内容：\n";

    int count = ;

    while()

    {

    //    if(write_over)

        {

            write_over = false;

            char msg[] = {};

            sprintf(msg, "第%d次发送信息！", ++count);

            bufferevent_write(bev, msg, strlen(msg) + );

            Sleep();

        }

    //    Sleep(50);

    }

    th.join();

    std::cout<<" over!\n";

    getchar();

    return ;

}

server.cpp

// App01.cpp : 定义控制台应用程序的入口点。

//

#include <string.h>

#include <errno.h>

#include <stdio.h>

#include <signal.h>

#ifndef WIN32

#include <netinet/in.h>

# ifdef _XOPEN_SOURCE_EXTENDED

#  include <arpa/inet.h>

# endif

#include <sys/socket.h>

#endif

#include <event2/thread.h>

#include <event2/bufferevent.h>

#include <event2/buffer.h>

#include <event2/listener.h>

#include <event2/util.h>

#include <event2/event.h>

#include <event2/bufferevent_struct.h>

#include <thread>

#include <iostream>

#include <vector>

/* 设置计数，只允许echo_write_cb调用一次 */

static int count = ;

static std::vector<struct bufferevent *> g_bev;//bufferevent缓冲区

/*当有数据可读的时候，会调用这个函数 */

//读取回调函数

static void echo_read_cb(struct bufferevent *bev, void *ctx)

{

    printf("读：echo_read_cb is called\n");

    char bufs[] = {};

    bufferevent_read(bev, bufs, sizeof(bufs));

    std::cout<< bufs <<"\n";

    return;

    printf("读：echo_read_cb is called\n");

    struct evbuffer *input = bufferevent_get_input(bev);

    struct evbuffer *output = bufferevent_get_output(bev);

    size_t len = evbuffer_get_length(input);

    printf("evbuffer input length is: %lu\n", (unsigned long)len);

    //evbuffer_add_buffer(output, input);

    char buf[];

    int n;

    n = evbuffer_remove(input, buf, sizeof(buf));

    printf("copy bytes == %d\n", n);

    printf("copy buf: %s\n", buf);

}

//写入回调函数

static void echo_write_cb(struct bufferevent *bev, void *ctx)

{

    printf("写：echo_write_cb is called\n");

    char sendbuffer[] = "yes, i recv your message!\n";

    return;

    struct evbuffer *output = bufferevent_get_output(bev);    

    if(count == )

    {

        int result = evbuffer_add(output, sendbuffer, strlen(sendbuffer));

        printf("evbuffer_add result = %d\n", result);

    }

    count++;

    int len = evbuffer_get_length(output);

    evbuffer_drain(output, len);

}

/*当客户端结束的时候，肯定会调用这个函数  */

//事件回调函数

static void echo_event_cb(struct bufferevent *bev, short events, void *ctx)

{

    printf("状态：echo_event_cb is called\n");

    if(events & BEV_EVENT_ERROR)

        perror("Error from bufferevent");

    if(events & BEV_EVENT_EOF | BEV_EVENT_ERROR)

    {

        bufferevent_free(bev);

        printf("bufferevent_free is called\n");

    }

    printf("-------------------------------\n\n");

}    

//client连接回调

static void accept_conn_cb(struct evconnlistener *listener, evutil_socket_t fd,

    struct sockaddr*address, int socklen, void *ctx)

{

    printf("连接：Accept_conn_cb is called\n");

    struct event_base *base = evconnlistener_get_base(listener);//返回监听器关联的event_base

    struct bufferevent *bev = bufferevent_socket_new(base, fd,//创建基于套接字的bufferevent

        BEV_OPT_CLOSE_ON_FREE | BEV_OPT_THREADSAFE);

    if (!bev)

    {

        fprintf(stderr, "Error constructing bufferevent!");

        event_base_loopbreak(base);

        return ;

    }

    g_bev.push_back(bev);

    bufferevent_setcb(bev, echo_read_cb, NULL, echo_event_cb, "Server参数");//设置读回调，错误事件回调,null表示禁止回调，cbarg向回调传递参数

    bufferevent_enable(bev, EV_READ|EV_WRITE);    //开启缓冲区上的读，写事件

}

//连接监听器错误回调函数

static void accept_error_cb(struct evconnlistener *listener, void *ctx)

{

    printf("监听错误：Accept_error_cb is called\n");

    struct event_base *base = evconnlistener_get_base(listener);

    int err = EVUTIL_SOCKET_ERROR();

    fprintf(stderr, "Got an error");

    event_base_loopexit(base, NULL);

}

struct event_base *g_base;

int main(int argc, char **argv)

{

    struct evconnlistener *listener;

    struct sockaddr_in sin;

    int port = ;

    if(argc > )

    {

        port = atoi(argv[]);

    }

    if(port <=  || port > )

    {

        puts("Invalid port");

        return ;

    }

#ifdef WIN32

    WSADATA wsa_data;

    WSAStartup(0x0201, &wsa_data);//启动异步socket

#endif

    if(- == evthread_use_windows_threads())//event多线程支持

        return false;

    g_base = event_base_new();//创建一个event_base

    if(!g_base)

    {

        puts("could't open event_base");

        return ;

    }

    memset(&sin, , sizeof(sin));

    sin.sin_family = AF_INET;

    sin.sin_addr.s_addr = htonl();

    sin.sin_port = htons(port);

    //分配返回一个监听器对象，有连接会回调accept_conn_cb函数,绑定iP,port

    listener = evconnlistener_new_bind(g_base, accept_conn_cb, NULL,

        LEV_OPT_CLOSE_ON_FREE|LEV_OPT_REUSEABLE, -,

        (struct sockaddr*)&sin, sizeof(sin));

    if(!listener)

    {

        perror("could't not create listener");

        return ;

    }

    evconnlistener_set_error_cb(listener, accept_error_cb);//侦听错误

    std::thread th([]

    {

        event_base_dispatch(g_base);//程序进入无线循环，等待就绪事件并执行事件处理

    });

    int count = ;

    for(;;)

    {

        if(!g_bev.empty())

        {

            for(auto it : g_bev)

            {

                char msg[] = {};

                sprintf(msg, "欢迎！Server send!%d", count);

                bufferevent_write(it, msg, );//想缓冲区添加数据

            }

            count++;

        }

        Sleep();

    }

    th.join();

    return ;

}

//每个bufferevent有两个数据相关的回调：一个读取回调和一个写入回调。
//默认情况下，从底层传输端口读取了任意量的数据之后会调用读取回调；
//输出缓冲区中足够量的数据被清空到底层传输端口后写入回调会被调用。
//通过调整bufferevent的读取和写入“水位（watermarks）”可以覆盖这些函数的默认行为。

最新文章

  1. mui框架中底部导航的跳转2
  2. spring quartz分布式任务计划
  3. js 爱恨情仇说 this
  4. mysql 按距离今日时间最近排序
  5. Spring和cxf3的整合，以maven的方式
  6. cocos2dx的内存管理机制
  7. AVL树的旋转实现
  8. 二进制序列化框架easypack发布啦！
  9. HDU 3569 Imaginary Date 简单期望
  10. C# 8.0的三个值得关注的新特性
  11. 利用PHP+MySql+Ajax操作实现年月日联动功能
  12. 【资料下载区】【GMT43相关代码、资料下载地址】更新日期2017/06/28
  13. 【Tools】-NO.93.Tools.5.pyCharm-【pyCharm 安装与破解配置】-
  14. 在linux环境下编译android so库
  15. Reveal使用
  16. bundle adjustment原理(1)
  17. 1, 2, and 4 symbols per clock中数据排列
  18. 技术笔记2 jetty jboss
  19. SQL Server中动态列转行
  20. [转] Ansible 进阶 | facts 缓存

热门文章

  1. Java的内存机制（转）
  2. Linux内核project导论——网络：路由：路由原理
  3. 0基础的小白怎么学习Java？
  4. Bootstrap学习笔记 Well
  5. SQL中intersect、union、minus和except 运算符
  6. Mac / Windows 下的 FTP 工具filezilla
  7. vb.net winform exe 接参数
  8. JUC组件扩展（二）-JAVA并行框架Fork/Join（一）：简介和代码示例
  9. [docker]docker run指定entrypiont
  10. Android Studio编译的时候提示Gradle无法下载的解决方案