基于libuv库的tcp, udp echo服务器和客户段测试python代码。

TCP 客户端测试python代码:

import socket
import time

def tcpClient():
    for i in range(10000):
        clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        clisock.connect((‘localhost‘, 7890))
        clisock.send(‘Hi Doudou‘)
        dat = clisock.recv(30)
        print dat
        clisock.close()
    print "----------------11111111------------------------" 
    clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    clisock.connect((‘localhost‘, 7890))
    for i in range(100000):
        clisock.send(‘Hi Doudou‘)
        dat = clisock.recv(30)
        print dat



if __name__ ==  ‘__main__‘:
    start = time.time()
    tcpClient()
    print "total time ",  time.time() - start

UDP端测试python代码:

import socket
host = "127.0.0.1"
port = 7890

print "python UDP echo server test"

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)

s.bind((host, 2346))
msg = ""
for i in range(1, 100000):
    if i % 2 == 0:
        msg = "NO:%d hello libuv udp" % i
    else:
        msg = "NO:%d I am here" % i
    s.sendto(msg, (host, port))
    message, address = s.recvfrom(1234)
    print "Got data from", address, ":", message


TCP和UDP echo服务器代码:

#include <uv.h>
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <string.h>


#define TEST_PORT  7890

typedef struct {
	uv_write_t req;
	uv_buf_t buf;
} write_req_t;

static uv_udp_t udp_sv;
static uv_udp_t udp_cl;
static uv_loop_t *loop;

static uv_tcp_t tcp_sv;
static uv_tcp_t tcp_cl;
static int con_count;


static int udp_echo_start(int port);
static int tcp_echo_start(int port);
static uv_buf_t udp_alloc_cb(uv_handle_t* handle, size_t suggested_size);
static uv_buf_t tcp_alloc_cb(uv_handle_t* handle, size_t suggested_size);
static void udp_sv_send_cb(uv_udp_send_t* req, int status);
static void udp_close_cb(uv_handle_t* handle);
static void on_connection(uv_stream_t* server, int status);
static void tcp_sv_recv_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf);
static void after_write(uv_write_t* req, int status);
static void on_close(uv_handle_t* peer);
static void after_shutdown(uv_shutdown_t* req, int status);
static void udp_sv_recv_cb(uv_udp_t* handle,
		       ssize_t nread,
		       uv_buf_t buf,
		       struct sockaddr* addr,
                       unsigned flags);

static uv_buf_t udp_alloc_cb(uv_handle_t* handle, size_t suggested_size)
{
	static char slab[65536];

	assert(suggested_size <= sizeof slab);

	return uv_buf_init(slab, sizeof slab);
}

static uv_buf_t tcp_alloc_cb(uv_handle_t* handle, size_t suggested_size)
{
	return uv_buf_init(malloc(suggested_size), suggested_size);
}

static void after_write(uv_write_t* req, int status)
{
	write_req_t *wr;
	uv_err_t err;
	wr = (write_req_t *) req;

	
	free(wr->buf.base);
	free(wr);

	if (status == 0)
		return;
	err = uv_last_error(loop);
	fprintf(stderr, "uv_write_error: %s\n", uv_strerror(err));
	if (err.code == UV_ECANCELED)
		return;

	assert(err.code == UV_EPIPE);
}

static void on_close(uv_handle_t* peer)
{
	free(peer);
}


static void after_shutdown(uv_shutdown_t* req, int status)
{
	uv_close((uv_handle_t*)req->handle, on_close);

	free(req);
}

static void tcp_sv_recv_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf)
{
	int i;
	uv_shutdown_t *req;
	write_req_t *wr;

	if (nread < 0) {
		/* Error or EOF */
		free(buf.base);    // 忘记在这里释放分配的内存,程序内存泄露了,程序处理几万次读写后挂掉了!!!!
		assert(uv_last_error(loop).code == UV_EOF);
		req = (uv_shutdown_t*) malloc(sizeof *req);
		uv_shutdown(req, handle, after_shutdown);
		return;
	}

	if (nread == 0) {
		/* Everything OK, but nothing read. */
		return;
	}

	wr = malloc(sizeof(*wr));
	assert(wr != NULL);

	buf.len = nread;
	wr->buf = buf;
	
	if (uv_write(&wr->req, handle, &wr->buf, 1, after_write)) {
		printf("uv_write_failed\n");
	}

}

static void udp_close_cb(uv_handle_t* handle)
{
}


static void udp_sv_send_cb(uv_udp_send_t* req, int status)
{
	uv_err_t err;

	if (status != 0) {
		err = uv_last_error(loop);
		fprintf(stderr, "uv_udp_send error:%s\n", uv_strerror(err));
	
	}
	
	assert(status == 0);
//	uv_close((uv_handle_t*) req->handle, udp_close_cb);
	free(req);
}


static void udp_sv_recv_cb(uv_udp_t* handle,
                       ssize_t nread,
                       uv_buf_t buf,
                       struct sockaddr* addr,
                       unsigned flags)
{
	uv_udp_send_t *req;
	int r;
	if (nread == 0) {
		return;
	}
//	r = uv_udp_recv_stop(handle);
//	assert(r == 0);
	
	req  = malloc(sizeof(*req));
	assert(req != NULL);
	
	buf.len = nread;
	r = uv_udp_send(req, handle, &buf, 1, *(struct sockaddr_in *)addr, udp_sv_send_cb);
	assert(r == 0);
}

static int udp_echo_start(int port)
{
	struct sockaddr_in addr;
	int r;

	addr = uv_ip4_addr("0.0.0.0", port);
	r = uv_udp_init(loop, &udp_sv);
	assert(r == 0);

	r = uv_udp_bind(&udp_sv, addr, 0);
	assert(r == 0);
	
	r = uv_udp_recv_start(&udp_sv, udp_alloc_cb , udp_sv_recv_cb);
	assert(r == 0);
	
	r = uv_udp_init(loop, &udp_cl);
	assert(r == 0);
	
	
	return 0;
}

static void on_connection(uv_stream_t* server, int status)
{
	uv_stream_t *stream;
	int r;

	stream = malloc(sizeof(uv_tcp_t));
	assert(stream != NULL);

	r = uv_tcp_init(loop, (uv_tcp_t*)stream);
	assert(r == 0);
	
	stream->data = server;

	r = uv_accept(server, stream);
	assert(r == 0);

	r = uv_read_start(stream, tcp_alloc_cb, tcp_sv_recv_cb);
	assert(r == 0);
}

static int tcp_echo_start(int port)
{
	struct sockaddr_in addr = uv_ip4_addr("0.0.0.0", port);
	int r;

	r = uv_tcp_init(loop, &tcp_sv);
	assert(r== 0);

	r = uv_tcp_bind(&tcp_sv, addr);
	assert(r == 0);

	r = uv_listen((uv_stream_t *)&tcp_sv, SOMAXCONN, on_connection);
	assert(r == 0);
	
	return 0;
}

int main()
{
	loop = uv_default_loop();
	
	if (tcp_echo_start(TEST_PORT))
		return 1;

	if (udp_echo_start(TEST_PORT))
		return 1;
	
	uv_run(loop, UV_RUN_DEFAULT);
	return 0;
}


在写TCP部分的时候在处理客户端关闭连接时忘记释放读内存,结果程序内存泄露,处理几万个读时间后程序刮掉了,非配内存返回0。

基于libuv库的tcp, udp echo服务器和客户段测试python代码。,布布扣,bubuko.com

基于libuv库的tcp, udp echo服务器和客户段测试python代码。

上一篇:libcoro:在c++中支持coroutine


下一篇:Effective C++ 读书笔记(39-45)