# zxc_net

**Repository Path**: zput/zxc_net

## Basic Information

- **Project Name**: zxc_net
- **Description**: A multi threads network library
- **Primary Language**: C++
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-02-05
- **Last Updated**: 2020-12-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# zxc_net
A multi threads network library

## 简介
zxc_net是基于Reactor模式的多线程C++网络库

- 依赖于C++11提供的std::thread库,多线程表现在: 
    1. 为accept socket 的线程中的acceptFd 开启SO_RESUEPORT选项，多个线程拥有自己的Acceptor进行接收客户端连接.   
    2. 为每个拥有acceptFd的线程建立了线程池, 便于分发接收到的clientFd.   解决了TCP连接负载均衡的问题, 减少客户连接等待时间. 

- 非阻塞的poll模式,
- 拥有read/write buff缓冲区, readv + LT 触发可以读取较大数据.


## 例子

一个简单的echo服务器：
main函数如下：

```c++
int main() {
	
	//  setLogLevel(LOG_LEVEL_INFO);
	
	
	INFO("I'm enter\n");
	
	using namespace zxc_net;

	EventLoop loopF;
	EventLoop* loop = &loopF;

	std::string ip = "192.168.5.129";
	uint16_t port = 30005;
	InetAddress local(ip,port);

	TcpServerMulti  serverAll(loop, local);

	serverAll.setConnectionCallback(onConnection);
	serverAll.setMessageCallback(messageFunction);

	serverAll.setNumThread(1);
	serverAll.start();

	loopF.runAfter(Second(2), runInThread);
	loopF.loop();

}
```



这个实现非常简单，可以看到`messageFunction`回调函数，它将收到消息重新发给客户端。

```c++
void messageFunction(const std::shared_ptr<zxc_net::TcpConnection> & conn, zxc_net::Buffer& buf) {

	int p = buf.readableBytes();
	std::string ps = buf.retrieveAllAsString();
	INFO("onMessage(): received %zd bytes from connection [%zd] at %s\n",
		buf.readableBytes(),
		p,
		ps.c_str());
    INFO("client:%s\n",ps.c_str());
	conn->send(ps);

}

void runInThread()
{
	INFO("\nrunInThread(): pid = %d, tid \n", getpid());
}
```

![](zxc_echo.png)


## 安装

```sh
$ ./build.sh 
$ ./build.sh install

```
安装在 `../zxc_net-build/Release/{include, lib, bin}`