恋恋风辰的官方博客

聊天项目(14) 登录功能和状态服务
Posted on 2024-05-02 08:49:09 by 恋恋风辰 | In C++ | 原文链接

客户端登录功能

登录界面新增err_tip，用来提示用户登陆结果。至于密码输入框大家可以根据注册界面的逻辑实现隐藏和显示的功能。这里留给大家自己实现。

https://cdn.llfc.club/1713228480446.jpg

点击登录需要发送http 请求到GateServer，GateServer先验证登录密码，再调用grpc请求给StatusServer，获取聊天服务器ip信息和token信息反馈给客户端。

结构图如下

https://cdn.llfc.club/1713230325540.jpg

我们先实现客户端登录,为登录按钮添加槽函数响应

  1. void LoginDialog::on_login_btn_clicked()
  2. {
  3.     qDebug()<<"login btn clicked";
  4.     if(checkUserValid() == false){
  5.         return;
  6.     }
  8.     if(checkPwdValid() == false){
  9.         return ;
  10.     }
  12.     auto user = ui->user_edit->text();
  13.     auto pwd = ui->pass_edit->text();
  14.     //发送http请求登录
  15.     QJsonObject json_obj;
  16.     json_obj["user"] = user;
  17.     json_obj["passwd"] = xorString(pwd);
  18.     HttpMgr::GetInstance()->PostHttpReq(QUrl(gate_url_prefix+"/user_login"),
  19.                                         json_obj, ReqId::ID_LOGIN_USER,Modules::LOGINMOD);
  20. }

增加检测函数

  1. bool LoginDialog::checkUserValid(){
  3.     auto user = ui->user_edit->text();
  4.     if(user.isEmpty()){
  5.         qDebug() << "User empty " ;
  6.         return false;
  7.     }
  9.     return true;
  10. }
  12. bool LoginDialog::checkPwdValid(){
  13.     auto pwd = ui->pass_edit->text();
  14.     if(pwd.length() < 6 || pwd.length() > 15){
  15.         qDebug() << "Pass length invalid";
  16.         return false;
  17.     }
  19.     return true;
  20. }

在HttpMgr中添加sig_login_mod_finish信号，收到http请求完成回包的槽函数中添加登录模块的响应，将登录模块的消息发送到登录界面

  1. void HttpMgr::slot_http_finish(ReqId id, QString res, ErrorCodes err, Modules mod)
  2. {
  3.     if(mod == Modules::REGISTERMOD){
  4.         //发送信号通知指定模块http响应结束
  5.         emit sig_reg_mod_finish(id, res, err);
  6.     }
  8.     if(mod == Modules::RESETMOD){
  9.         //发送信号通知指定模块http响应结束
  10.         emit sig_reset_mod_finish(id, res, err);
  11.     }
  13.     if(mod == Modules::LOGINMOD){
  14.         emit sig_login_mod_finish(id, res, err);
  15.     }
  16. }

在LoginDialog的构造函数中添加消息对应的槽函数连接

  1. LoginDialog::LoginDialog(QWidget *parent) :
  2.     QDialog(parent),
  3.     ui(new Ui::LoginDialog)
  4. {
  5.     ui->setupUi(this);
  6.     connect(ui->reg_btn, &QPushButton::clicked, this, &LoginDialog::switchRegister);
  7.     ui->forget_label->SetState("normal","hover","","selected","selected_hover","");
  8.     ui->forget_label->setCursor(Qt::PointingHandCursor);
  9.     connect(ui->forget_label, &ClickedLabel::clicked, this, &LoginDialog::slot_forget_pwd);
  10.     initHttpHandlers();
  11.     //连接登录回包信号
  12.     connect(HttpMgr::GetInstance().get(), &HttpMgr::sig_login_mod_finish, this,
  13.             &LoginDialog::slot_login_mod_finish);
  14. }

initHttpHandlers为初始化http回调逻辑, 并添加_handlers成员

  1. void LoginDialog::initHttpHandlers()
  2. {
  3.     //注册获取登录回包逻辑
  4.     _handlers.insert(ReqId::ID_LOGIN_USER, [this](QJsonObject jsonObj){
  5.         int error = jsonObj["error"].toInt();
  6.         if(error != ErrorCodes::SUCCESS){
  7.             showTip(tr("参数错误"),false);
  8.             return;
  9.         }
  10.         auto user = jsonObj["user"].toString();
  11.         showTip(tr("登录成功"), true);
  12.         qDebug()<< "user is " << user ;
  13.     });
  14. }

在LoginDialog中添加槽函数slot_login_mod_finish

  1. void LoginDialog::slot_login_mod_finish(ReqId id, QString res, ErrorCodes err)
  2. {
  3.     if(err != ErrorCodes::SUCCESS){
  4.         showTip(tr("网络请求错误"),false);
  5.         return;
  6.     }
  8.     // 解析 JSON 字符串,res需转化为QByteArray
  9.     QJsonDocument jsonDoc = QJsonDocument::fromJson(res.toUtf8());
  10.     //json解析错误
  11.     if(jsonDoc.isNull()){
  12.         showTip(tr("json解析错误"),false);
  13.         return;
  14.     }
  16.     //json解析错误
  17.     if(!jsonDoc.isObject()){
  18.         showTip(tr("json解析错误"),false);
  19.         return;
  20.     }
  23.     //调用对应的逻辑,根据id回调。
  24.     _handlers[id](jsonDoc.object());
  26.     return;
  27. }

到此客户端登陆请求发送的模块封装完了

GateServer完善登陆逻辑

在LogicSystem的构造函数中添加登陆请求的注册。

  1. //用户登录逻辑
  2. RegPost("/user_login", [](std::shared_ptr<HttpConnection> connection) {
  3.     auto body_str = boost::beast::buffers_to_string(connection->_request.body().data());
  4.     std::cout << "receive body is " << body_str << std::endl;
  5.     connection->_response.set(http::field::content_type, "text/json");
  6.     Json::Value root;
  7.     Json::Reader reader;
  8.     Json::Value src_root;
  9.     bool parse_success = reader.parse(body_str, src_root);
  10.     if (!parse_success) {
  11.         std::cout << "Failed to parse JSON data!" << std::endl;
  12.         root["error"] = ErrorCodes::Error_Json;
  13.         std::string jsonstr = root.toStyledString();
  14.         beast::ostream(connection->_response.body()) << jsonstr;
  15.         return true;
  16.     }
  18.     auto name = src_root["user"].asString();
  19.     auto pwd = src_root["passwd"].asString();
  20.     UserInfo userInfo;
  21.     //查询数据库判断用户名和密码是否匹配
  22.     bool pwd_valid = MysqlMgr::GetInstance()->CheckPwd(name, pwd, userInfo);
  23.     if (!pwd_valid) {
  24.         std::cout << " user pwd not match" << std::endl;
  25.         root["error"] = ErrorCodes::PasswdInvalid;
  26.         std::string jsonstr = root.toStyledString();
  27.         beast::ostream(connection->_response.body()) << jsonstr;
  28.         return true;
  29.     }
  31.     //查询StatusServer找到合适的连接
  32.     auto reply = StatusGrpcClient::GetInstance()->GetChatServer(userInfo.uid);
  33.     if (reply.error()) {
  34.         std::cout << " grpc get chat server failed, error is " << reply.error()<< std::endl;
  35.         root["error"] = ErrorCodes::RPCGetFailed;
  36.         std::string jsonstr = root.toStyledString();
  37.         beast::ostream(connection->_response.body()) << jsonstr;
  38.         return true;
  39.     }
  41.     std::cout << "succeed to load userinfo uid is " << userInfo.uid << std::endl;
  42.     root["error"] = 0;
  43.     root["user"] = name;
  44.     root["uid"] = userInfo.uid;
  45.     root["token"] = reply.token();
  46.     root["host"] = reply.host();
  47.     std::string jsonstr = root.toStyledString();
  48.     beast::ostream(connection->_response.body()) << jsonstr;
  49.     return true;
  50.     });

在MysqlMgr中添加CheckPwd函数

  1. bool MysqlMgr::CheckPwd(const std::string& name, const std::string& pwd, UserInfo& userInfo) {
  2.     return _dao.CheckPwd(name, pwd, userInfo);
  3. }

在DAO层添加根据用户名查询sql逻辑,并且判断pwd是否匹配。

  1. bool MysqlDao::CheckPwd(const std::string& name, const std::string& pwd, UserInfo& userInfo) {
  2.     auto con = pool_->getConnection();
  3.     Defer defer([this, &con]() {
  4.         pool_->returnConnection(std::move(con));
  5.         });
  7.     try {
  8.         if (con == nullptr) {
  9.             return false;
  10.         }
  12.         // 准备SQL语句
  13.         std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("SELECT * FROM user WHERE name = ?"));
  14.         pstmt->setString(1, name); // 将username替换为你要查询的用户名
  16.         // 执行查询
  17.         std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());
  18.         std::string origin_pwd = "";
  19.         // 遍历结果集
  20.         while (res->next()) {
  21.             origin_pwd = res->getString("pwd");
  22.             // 输出查询到的密码
  23.             std::cout << "Password: " << origin_pwd << std::endl;
  24.             break;
  25.         }
  27.         if (pwd != origin_pwd) {
  28.             return false;
  29.         }
  30.         userInfo.name = name;
  31.         userInfo.email = res->getString("email");
  32.         userInfo.uid = res->getInt("uid");
  33.         userInfo.pwd = origin_pwd;
  34.         return true;
  35.     }
  36.     catch (sql::SQLException& e) {
  37.         std::cerr << "SQLException: " << e.what();
  38.         std::cerr << " (MySQL error code: " << e.getErrorCode();
  39.         std::cerr << ", SQLState: " << e.getSQLState() << " )" << std::endl;
  40.         return false;
  41.     }
  42. }

因为要调用grpc访问StatusServer，所以我们这里先完善协议proto文件

  1. syntax = "proto3";
  3. package message;
  5. service VarifyService {
  6.   rpc GetVarifyCode (GetVarifyReq) returns (GetVarifyRsp) {}
  7. }
  9. message GetVarifyReq {
  10.   string email = 1;
  11. }
  13. message GetVarifyRsp {
  14.   int32 error = 1;
  15.   string email = 2;
  16.   string code = 3;
  17. }
  19. message GetChatServerReq {
  20.   int32 uid = 1;
  21. }
  23. message GetChatServerRsp {
  24.   int32 error = 1;
  25.   string host = 2;
  26.   string port = 3;
  27.   string token = 4;
  28. }
  30. service StatusService {
  31.     rpc GetChatServer (GetChatServerReq) returns (GetChatServerRsp) {}
  32. }

我们用下面两条命令重新生成pb.h和grpc.pb.h

  1. D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug\protoc.exe --cpp_out=. "message.proto"

生成grpc.pb.h

  1. D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug\protoc.exe  -I="." --grpc_out="." --plugin=protoc-gen-grpc="D:\cppsoft\grpc\visualpro\Debug\grpc_cpp_plugin.exe" "message.proto"

这俩命令执行完成后总计生成四个文件

https://cdn.llfc.club/1713239066360.jpg

实现StatusGrpcClient

  1. #include "const.h"
  2. #include "Singleton.h"
  3. #include "ConfigMgr.h"
  5. using grpc::Channel;
  6. using grpc::Status;
  7. using grpc::ClientContext;
  9. using message::GetChatServerReq;
  10. using message::GetChatServerRsp;
  11. using message::StatusService;
  13. class StatusGrpcClient :public Singleton<StatusGrpcClient>
  14. {
  15.     friend class Singleton<StatusGrpcClient>;
  16. public:
  17.     ~StatusGrpcClient() {
  19.     }
  20.     GetChatServerRsp GetChatServer(int uid);
  22. private:
  23.     StatusGrpcClient();
  24.     std::unique_ptr<StatusConPool> pool_;
  26. };

具体实现

  1. #include "StatusGrpcClient.h"
  3. GetChatServerRsp StatusGrpcClient::GetChatServer(int uid)
  4. {
  5.     ClientContext context;
  6.     GetChatServerRsp reply;
  7.     GetChatServerReq request;
  8.     request.set_uid(uid);
  9.     auto stub = pool_->getConnection();
  10.     Status status = stub->GetChatServer(&context, request, &reply);
  11.     Defer defer([&stub, this]() {
  12.         pool_->returnConnection(std::move(stub));
  13.         });
  14.     if (status.ok()) {    
  15.         return reply;
  16.     }
  17.     else {
  18.         reply.set_error(ErrorCodes::RPCFailed);
  19.         return reply;
  20.     }
  21. }
  23. StatusGrpcClient::StatusGrpcClient()
  24. {
  25.     auto& gCfgMgr = ConfigMgr::Inst();
  26.     std::string host = gCfgMgr["StatusServer"]["Host"];
  27.     std::string port = gCfgMgr["StatusServer"]["Port"];
  28.     pool_.reset(new StatusConPool(5, host, port));
  29. }

当然GateServer的config.ini文件也要做更新

  1. [GateServer]
  2. Port = 8080
  3. [VarifyServer]
  4. Host = 127.0.0.1
  5. Port = 50051
  6. [StatusServer]
  7. Host = 127.0.0.1
  8. Port = 50052
  9. [Mysql]
  10. Host = 81.68.86.146
  11. Port = 3308
  12. User = root
  13. Passwd = 123456
  14. Schema = llfc
  15. [Redis]
  16. Host = 81.68.86.146
  17. Port = 6380
  18. Passwd = 123456

StatusGrpcClient用到了StatusConPool, 将其实现放在StatusGrpcClient类之上

  1. class StatusConPool {
  2. public:
  3.     StatusConPool(size_t poolSize, std::string host, std::string port)
  4.         : poolSize_(poolSize), host_(host), port_(port), b_stop_(false) {
  5.         for (size_t i = 0; i < poolSize_; ++i) {
  7.             std::shared_ptr<Channel> channel = grpc::CreateChannel(host + ":" + port,
  8.                 grpc::InsecureChannelCredentials());
  10.             connections_.push(StatusService::NewStub(channel));
  11.         }
  12.     }
  14.     ~StatusConPool() {
  15.         std::lock_guard<std::mutex> lock(mutex_);
  16.         Close();
  17.         while (!connections_.empty()) {
  18.             connections_.pop();
  19.         }
  20.     }
  22.     std::unique_ptr<StatusService::Stub> getConnection() {
  23.         std::unique_lock<std::mutex> lock(mutex_);
  24.         cond_.wait(lock, [this] {
  25.             if (b_stop_) {
  26.                 return true;
  27.             }
  28.             return !connections_.empty();
  29.             });
  30.         //如果停止则直接返回空指针
  31.         if (b_stop_) {
  32.             return  nullptr;
  33.         }
  34.         auto context = std::move(connections_.front());
  35.         connections_.pop();
  36.         return context;
  37.     }
  39.     void returnConnection(std::unique_ptr<StatusService::Stub> context) {
  40.         std::lock_guard<std::mutex> lock(mutex_);
  41.         if (b_stop_) {
  42.             return;
  43.         }
  44.         connections_.push(std::move(context));
  45.         cond_.notify_one();
  46.     }
  48.     void Close() {
  49.         b_stop_ = true;
  50.         cond_.notify_all();
  51.     }
  53. private:
  54.     atomic<bool> b_stop_;
  55.     size_t poolSize_;
  56.     std::string host_;
  57.     std::string port_;
  58.     std::queue<std::unique_ptr<StatusService::Stub>> connections_;
  59.     std::mutex mutex_;
  60.     std::condition_variable cond_;
  61. };

StatusServer状态服务

我们要实现状态服务，主要是用来监听其他服务器的查询请求, 用visual studio创建项目，名字为StatusServer.

在主函数所在文件StatusServer.cpp中实现如下逻辑

  1. #include <iostream>
  2. #include <json/json.h>
  3. #include <json/value.h>
  4. #include <json/reader.h>
  5. #include "const.h"
  6. #include "ConfigMgr.h"
  7. #include "hiredis.h"
  8. #include "RedisMgr.h"
  9. #include "MysqlMgr.h"
  10. #include "AsioIOServicePool.h"
  11. #include <iostream>
  12. #include <memory>
  13. #include <string>
  14. #include <thread>
  15. #include <boost/asio.hpp>
  16. #include "StatusServiceImpl.h"
  17. void RunServer() {
  18.     auto & cfg = ConfigMgr::Inst();
  20.     std::string server_address(cfg["StatusServer"]["Host"]+":"+ cfg["StatusServer"]["Port"]);
  21.     StatusServiceImpl service;
  23.     grpc::ServerBuilder builder;
  24.     // 监听端口和添加服务
  25.     builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  26.     builder.RegisterService(&service);
  28.     // 构建并启动gRPC服务器
  29.     std::unique_ptr<grpc::Server> server(builder.BuildAndStart());
  30.     std::cout << "Server listening on " << server_address << std::endl;
  32.     // 创建Boost.Asio的io_context
  33.     boost::asio::io_context io_context;
  34.     // 创建signal_set用于捕获SIGINT
  35.     boost::asio::signal_set signals(io_context, SIGINT, SIGTERM);
  37.     // 设置异步等待SIGINT信号
  38.     signals.async_wait([&server](const boost::system::error_code& error, int signal_number) {
  39.         if (!error) {
  40.             std::cout << "Shutting down server..." << std::endl;
  41.             server->Shutdown(); // 优雅地关闭服务器
  42.         }
  43.         });
  45.     // 在单独的线程中运行io_context
  46.     std::thread([&io_context]() { io_context.run(); }).detach();
  48.     // 等待服务器关闭
  49.     server->Wait();
  50.     io_context.stop(); // 停止io_context
  51. }
  53. int main(int argc, char** argv) {
  54.     try {
  55.         RunServer();
  56.     }
  57.     catch (std::exception const& e) {
  58.         std::cerr << "Error: " << e.what() << std::endl;
  59.         return EXIT_FAILURE;
  60.     }
  62.     return 0;
  63. }

在开始逻辑之前，我们需要先更新下config.ini文件

  1. [StatusServer]
  2. Port = 50052
  3. Host = 0.0.0.0
  4. [Mysql]
  5. Host = 81.68.86.146
  6. Port = 3308
  7. User = root
  8. Passwd = 123456
  9. Schema = llfc
  10. [Redis]
  11. Host = 81.68.86.146
  12. Port = 6380
  13. Passwd = 123456
  14. [ChatServer1]
  15. Host = 127.0.0.1
  16. Port = 8090
  17. [ChatServer2]
  18. Host = 127.0.0.1
  19. Port = 8091

然后我们将GateServer之前生成的pb文件和proto文件拷贝到StatusServer中。并且加入到项目中。

我们在项目中添加一个新的类StatusServiceImpl，该类主要继承自StatusService::Service。

  1. #include <grpcpp/grpcpp.h>
  2. #include "message.grpc.pb.h"
  4. using grpc::Server;
  5. using grpc::ServerBuilder;
  6. using grpc::ServerContext;
  7. using grpc::Status;
  8. using message::GetChatServerReq;
  9. using message::GetChatServerRsp;
  10. using message::StatusService;
  12. struct ChatServer {
  13.     std::string host;
  14.     std::string port;
  15. };
  16. class StatusServiceImpl final : public StatusService::Service
  17. {
  18. public:
  19.     StatusServiceImpl();
  20.     Status GetChatServer(ServerContext* context, const GetChatServerReq* request,
  21.         GetChatServerRsp* reply) override;
  23.     std::vector<ChatServer> _servers;
  24.     int _server_index;
  25. };

具体实现

  1. #include "StatusServiceImpl.h"
  2. #include "ConfigMgr.h"
  3. #include "const.h"
  5. std::string generate_unique_string() {
  6.     // 创建UUID对象
  7.     boost::uuids::uuid uuid = boost::uuids::random_generator()();
  9.     // 将UUID转换为字符串
  10.     std::string unique_string = to_string(uuid);
  12.     return unique_string;
  13. }
  15. Status StatusServiceImpl::GetChatServer(ServerContext* context, const GetChatServerReq* request, GetChatServerRsp* reply)
  16. {
  17.     std::string prefix("llfc status server has received :  ");
  18.     _server_index = (_server_index++) % (_servers.size());
  19.     auto &server = _servers[_server_index];
  20.     reply->set_host(server.host);
  21.     reply->set_port(server.port);
  22.     reply->set_error(ErrorCodes::Success);
  23.     reply->set_token(generate_unique_string());
  24.     return Status::OK;
  25. }
  27. StatusServiceImpl::StatusServiceImpl():_server_index(0)
  28. {
  29.     auto& cfg = ConfigMgr::Inst();
  30.     ChatServer server;
  31.     server.port = cfg["ChatServer1"]["Port"];
  32.     server.host = cfg["ChatServer1"]["Host"];
  33.     _servers.push_back(server);
  35.     server.port = cfg["ChatServer2"]["Port"];
  36.     server.host = cfg["ChatServer2"]["Host"];
  37.     _servers.push_back(server);
  38. }

其余的文件为了保持复用，我们不重复开发，将GateServer中的RedisMgr,MysqlMgr,Singleton,IOSerivePool等统统拷贝过来并添加到项目中。

联调测试

我们启动StatusServer，GateServer以及QT客户端，输入密码和用户名，点击登陆，会看到前端收到登陆成功的消息

https://cdn.llfc.club/1713248019373.jpg

热门评论
点击查看更多评论 没有更多评论了,点击收起 展开评论

热门文章

  1. C++ 类的继承封装和多态
    喜欢(588) 浏览(4298)

  2. Linux环境搭建和编码
    喜欢(594) 浏览(9927)

  3. windows环境搭建和vscode配置
    喜欢(587) 浏览(2300)

  4. slice介绍和使用
    喜欢(521) 浏览(2228)

  5. 解密定时器的实现细节
    喜欢(566) 浏览(3033)

最新评论

  1. asio多线程模型IOServicePool Lion:线程池一定要继承单例模式吗
  2. 泛型算法的定制操作 secondtonone1:lambda和bind是C11新增的利器，善于利用这两个机制可以极大地提升编程安全性和效率。
  3. 类和对象 陈宇航:支持！！！！
  4. C++ 虚函数表原理和类成员内存分布 WangQi888888:class Test{ int m; int b; }中b成员是int，为什么在内存中只占了1个字节。不应该是4个字节吗？是不是int应该改为char。这样的话就会符合图上说明的情况
  5. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理，无论工作也好生活也罢，最重要的是开心，即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃，所以我还是想去做喜欢的方向。

其他链接

  1. GitHub
  2. 个人博客
  3. 博客园
  4. CSDN

个人公众号

个人微信