jwNet

#include "Network.h"
using namespace net;

#define BUFFLEN 1024

class Connect : public IoSocket
{
protected:
	virtual void onConnect(int err) {}
	virtual void onWrite(int bytes, int err) {}

	virtual void onRead(int bytes, int err){
		if (bytes <= 0 || err) {
			return;
		}
		printf("recv msg: %s\n", readbuff);
		postRead();
	}

public:
	void postRead(){
		//Request to read data
		IoSocket::read(readbuff, BUFFLEN);
	}

private:
	char readbuff[BUFFLEN];
};

class IServer : public Accept
{
public:
	virtual void onAccept(IoSockptr& sptr, int err) {
		if (err){
			accept(sptr);
		}
		else {
			((Connect*)sptr.get())->postRead();
			accept(std::make_shared<Connect>());
		}
	}
};

int main()
{
	NetLoop loop;
	loop.init();

	IServer accept;
	accept.listen(&loop, "127.0.0.1", 6601);
	accept.accept(std::make_shared<Connect>());

	while (1) {
		loop.run(5);
	}
	return 0;
}