server_example.c

这是封装的socket库

#include "tcpsocketserver.h"

void recv_callback(void *param, int socket, char *buf, int len, int flags)
{
	char buf2[8000];
	server_ctx_t *server_ctx = (server_ctx_t *)param;
//	fprintf(stderr,"param:%s\n",(char *)param);
	fprintf(stderr,"line:%d recv fd:%d len:%d buf:%s\n",__LINE__,socket, len,buf);
	memset(buf2,1,sizeof(buf2));
	server_ctx->interface.interface_send(&(server_ctx->interface),buf2,8000,0);
	

}

void disconnect_callback(void *param, int socket)
{
	fprintf(stderr,"lien:%d,disconnect fd:%d\n",__LINE__,socket);
}
int main()
{
	int ret;
	char *recv_msg = "recv message \n";
	char *disconnect_msg = "disconnect message \n";
	server_ctx_t *server_ctx = server_new();
	if(server_ctx == NULL)
	{
		fprintf(stderr,"Failed to malloc server_ctx.\n");
		return -1;
	}	

	ret = server_init(server_ctx);
	if(ret != 0)
	{
		
		fprintf(stderr,"Failed to init server_ctx.\n");
		return -1;
	}
	server_ctx->interface.set_recv_callback(&(server_ctx->interface),  recv_callback, server_ctx);
	server_ctx->interface.set_disconnect_callback(&(server_ctx->interface),  disconnect_callback, disconnect_msg);
	server_ctx->interface.interface_start(&(server_ctx->interface),"127.0.0.1",1000);
	while(1)
		;
}