您当前的位置: 首页 > 

qianbo_insist

暂无认证

  • 0浏览

    0关注

    399博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

libuv tcp client

qianbo_insist 发布时间:2021-08-09 22:27:38 ,浏览量:0

windows 和 linux 包含

windows下要包含一些lib库,这个需要加进去

#if defined (WIN32) || defined (_WIN32)
#include 
#include 
#pragma comment(lib,"ws2_32.lib")
#pragma comment(lib,"psapi.lib")
#pragma comment(lib,"Iphlpapi.lib")
#pragma comment(lib,"Userenv.lib")

#else
#include 
#include 
#endif
show me the code

为了和服务器链接测试使用的代码,以下是服务器代码

modbus tcp server 文章

#include 
#include 
#include 
#include 

#define DEFAULT_IP "127.0.0.1"
#define DEFAULT_PORT 7001

struct sockaddr_in dest;
uv_timer_t*  timer;
uv_loop_t* loop;
uv_write_t write_req;

void write_cb(uv_write_t* req, int status)
{
	if (status data;
	uv_stream_t* tcp = connect->handle;

	int buf_count = 1;

	uv_write(&write_req, tcp, &buff, buf_count, write_cb);
}

void on_connect(uv_connect_t* connect, int status)
{
	if (status data = connect;
	uv_timer_init(loop, timer);

	uv_timer_start(timer, timer_cb, 0, 300);

}

typedef struct client_context
{
	uv_loop_t * loop = NULL;
	uv_tcp_t  socket;
	uv_connect_t connect;
	//const char * ip;
	//uint16_t port;
	struct sockaddr_in dest;
	uv_write_t write_req;
}client_context;


int send(uint8_t * data, size_t len)
{
	return 0;
}
void init_client_context(client_context * cc,const char * ip,uint16_t port)
{
	if (cc == NULL)
		return;
	cc->loop = uv_default_loop();
	uv_tcp_init(cc->loop, &cc->socket);
	//cc->ip = ip;
	//cc->port = port;
	uv_ip4_addr(ip, port, &dest);
}

int connect(client_context * cc)
{
	if (cc == NULL)
		return -1;
	int ret = uv_tcp_connect(&cc->connect, &cc->socket, (const struct sockaddr*)&dest, on_connect);
	if (ret) {
		fprintf(stderr, "Connect error: %s\n", uv_strerror(ret));
		return 0;
	}
	return uv_run(loop, UV_RUN_DEFAULT);

}

int main(int argc, char **argv) {
	loop = uv_default_loop();
	uv_tcp_t  socket;
	uv_tcp_init(loop, &socket);

	uv_connect_t connect;

	uv_ip4_addr(DEFAULT_IP, DEFAULT_PORT, &dest);
	int ret = uv_tcp_connect(&connect, &socket, (const struct sockaddr*)&dest, on_connect);
	if (ret) {
		fprintf(stderr, "Connect error: %s\n", uv_strerror(ret));
		return 0;
	}
	return uv_run(loop, UV_RUN_DEFAULT);
}

代码比较简单,不做解释,请和服务端配合使用,需要修改端口。

关注
打赏
1663161521
查看更多评论
立即登录/注册

微信扫码登录

0.0389s