【Lars教程目錄】
Lars源代碼
https://github.com/aceld/Lars
【Lars系統(tǒng)概述】
第1章-概述
第2章-項目目錄構(gòu)建
【Lars系統(tǒng)之Reactor模型服務(wù)器框架模塊】
第1章-項目結(jié)構(gòu)與V0.1雛形
第2章-內(nèi)存管理與Buffer封裝
第3章-事件觸發(fā)EventLoop
第4章-鏈接與消息封裝
第5章-Client客戶端模型
第6章-連接管理及限制
第7章-消息業(yè)務(wù)路由分發(fā)機制
第8章-鏈接創(chuàng)建/銷毀Hook機制
第9章-消息任務(wù)隊列與線程池
第10章-配置文件讀寫功能
第11章-udp服務(wù)與客戶端
第12章-數(shù)據(jù)傳輸協(xié)議protocol buffer
第13章-QPS性能測試
第14章-異步消息任務(wù)機制
第15章-鏈接屬性設(shè)置功能
【Lars系統(tǒng)之DNSService模塊】
第1章-Lars-dns簡介
第2章-數(shù)據(jù)庫創(chuàng)建
第3章-項目目錄結(jié)構(gòu)及環(huán)境構(gòu)建
第4章-Route結(jié)構(gòu)的定義
第5章-獲取Route信息
第6章-Route訂閱模式
第7章-Backend Thread實時監(jiān)控
【Lars系統(tǒng)之Report Service模塊】
第1章-項目概述-數(shù)據(jù)表及proto3協(xié)議定義
第2章-獲取report上報數(shù)據(jù)
第3章-存儲線程池及消息隊列
【Lars系統(tǒng)之LoadBalance Agent模塊】
第1章-項目概述及構(gòu)建
第2章-主模塊業(yè)務(wù)結(jié)構(gòu)搭建
第3章-Report與Dns Client設(shè)計與實現(xiàn)
第4章-負(fù)載均衡模塊基礎(chǔ)設(shè)計
第5章-負(fù)載均衡獲取Host主機信息API
第6章-負(fù)載均衡上報Host主機信息API
第7章-過期窗口清理與過載超時(V0.5)
第8章-定期拉取最新路由信息(V0.6)
第9章-負(fù)載均衡獲取Route信息API(0.7)
第10章-API初始化接口(V0.8)
第11章-Lars Agent性能測試工具
第12章- Lars啟動工具腳本
16) 鏈接屬性設(shè)置功能
16.1 測試鏈接屬性
? 我們在基于lars_reactor開發(fā)的時候，可能有時候需要在寫消息回調(diào)的時候，希望conn綁定一些屬性。現(xiàn)在我們可以配置這種功能到net_connection上踪蹬。
lars_reactor/include/net_connection.h
#pragma once
#include <stdio.h>
/*
*
* 網(wǎng)絡(luò)通信的抽象類，任何需要進行收發(fā)消息的模塊，都可以實現(xiàn)該類
*
* */
class net_connection
{
public:
net_connection():param(NULL) {}
//發(fā)送消息的接口
virtual int send_message(const char *data, int datalen, int msgid) = 0;
virtual int get_fd() = 0;
void *param; //TCP客戶端可以 通過該參數(shù)傳遞一些自定義的參數(shù)
};
//創(chuàng)建鏈接/銷毀鏈接 要觸發(fā)的 回調(diào)函數(shù)類型
typedef void (*conn_callback)(net_connection *conn, void *args);
? 這里我們給net_connection類添加了一個param屬性歼疮，這樣，我們就可以綁定一些開發(fā)者自定義的參數(shù)和當(dāng)前鏈接進行綁定诈唬。注意韩脏，這里也提供了一個get_fd()的純虛函數(shù),目的是提供conn獲取當(dāng)前fd的數(shù)據(jù)。
16.2 完成Lars Reactor V0.12開發(fā)
server端
#include "tcp_server.h"
#include <string>
#include <string.h>
#include "config_file.h"
tcp_server *server;
//回顯業(yè)務(wù)的回調(diào)函數(shù)
void callback_busi(const char *data, uint32_t len, int msgid, net_connection *conn, void *user_data)
{
printf("callback_busi ...\n");
//直接回顯
conn->send_message(data, len, msgid);
printf("conn param = %s\n", (const char *)conn->param);
}
//打印信息回調(diào)函數(shù)
void print_busi(const char *data, uint32_t len, int msgid, net_connection *conn, void *user_data)
{
printf("recv client: [%s]\n", data);
printf("msgid: [%d]\n", msgid);
printf("len: [%d]\n", len);
}
//新客戶端創(chuàng)建的回調(diào)
void on_client_build(net_connection *conn, void *args)
{
int msgid = 101;
const char *msg = "welcome! you online..";
conn->send_message(msg, strlen(msg), msgid);
//將當(dāng)前的net_connection 綁定一個自定義參數(shù)铸磅，供我們開發(fā)者使用
const char *conn_param_test = "I am the conn for you!";
conn->param = (void*)conn_param_test;
}
//客戶端銷毀的回調(diào)
void on_client_lost(net_connection *conn, void *args)
{
printf("connection is lost !\n");
}
int main()
{
event_loop loop;
//加載配置文件
config_file::setPath("./serv.conf");
std::string ip = config_file::instance()->GetString("reactor", "ip", "0.0.0.0");
short port = config_file::instance()->GetNumber("reactor", "port", 8888);
printf("ip = %s, port = %d\n", ip.c_str(), port);
server = new tcp_server(&loop, ip.c_str(), port);
//注冊消息業(yè)務(wù)路由
server->add_msg_router(1, callback_busi);
server->add_msg_router(2, print_busi);
//注冊鏈接hook回調(diào)
server->set_conn_start(on_client_build);
server->set_conn_close(on_client_lost);
loop.event_process();
return 0;
}
? 我們在 on_client_build中赡矢，對創(chuàng)建鏈接做了conn的參數(shù)傳遞，然后通過路由業(yè)務(wù)的轉(zhuǎn)發(fā)阅仔，我們在callback_busi中吹散，得到了之前傳遞進去的參數(shù)。這樣對我們使用框架做一些復(fù)雜的業(yè)務(wù)八酒，需要綁定一些屬性給conn是有必要的空民。
client端
#include "tcp_client.h"
#include <stdio.h>
#include <string.h>
//客戶端業(yè)務(wù)
void busi(const char *data, uint32_t len, int msgid, net_connection *conn, void *user_data)
{
//得到服務(wù)端回執(zhí)的數(shù)據(jù)
char *str = NULL;
str = (char*)malloc(len+1);
memset(str, 0, len+1);
memcpy(str, data, len);
printf("recv server: [%s]\n", str);
printf("msgid: [%d]\n", msgid);
printf("len: [%d]\n", len);
}
//客戶端銷毀的回調(diào)
void on_client_build(net_connection *conn, void *args)
{
int msgid = 1;
const char *msg = "Hello Lars!";
conn->send_message(msg, strlen(msg), msgid);
}
//客戶端銷毀的回調(diào)
void on_client_lost(net_connection *conn, void *args)
{
printf("on_client_lost...\n");
printf("Client is lost!\n");
}
int main()
{
event_loop loop;
//創(chuàng)建tcp客戶端
tcp_client client(&loop, "127.0.0.1", 7777, "clientv0.6");
//注冊消息路由業(yè)務(wù)
client.add_msg_router(1, busi);
client.add_msg_router(101, busi);
//設(shè)置hook函數(shù)
client.set_conn_start(on_client_build);
client.set_conn_close(on_client_lost);
//開啟事件監(jiān)聽
loop.event_process();
return 0;
}
? 和之前的client無任何改變。
運行結(jié)果
- 服務(wù)端：
$ ./server
msg_router init...
ip = 127.0.0.1, port = 7777
create 0 thread
create 1 thread
create 2 thread
create 3 thread
create 4 thread
add msg cb msgid = 1
add msg cb msgid = 2
begin accept
begin accept
[thread]: get new connection succ!
callback_busi ...
conn param = I am the conn for you!
? 會發(fā)現(xiàn)我們是可以在callback中拿到conn的屬性
關(guān)于作者：
作者：Aceld(劉丹冰)
mail: danbing.at@gmail.com
github: https://github.com/aceld
原創(chuàng)書籍gitbook: http://legacy.gitbook.com/@aceld
原創(chuàng)聲明:未經(jīng)作者允許請勿轉(zhuǎn)載, 如果轉(zhuǎn)載請注明出處
