zeroc-ice的全双工通信策略

90 阅读 0 评论 60 点赞

我是靠谱客的博主活泼大山，最近开发中收集的这篇文章主要介绍zeroc-ice的全双工通信策略，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

在项目中，往往很多时候涉及全双工通信要求，zeroc-ice样例介绍很多异步通信的策略，

但我最近项目需求中，不仅是要全双工通信，还要求服务端需要明确每个客户端及区别对待，

所以需要给每个客户端做标记处理

1）ice定义

#pragma once
#include <Ice/Identity.ice>

module TestIce
{

struct DateTimeI {
int isec;
int imsec;
};

interface ClientAchieve
{

//客户端实现

void PValueChange_A(long devID,long pID, DateTimeI itime, float val);//A类客户端实现

void PValueChange_B(long devID,long pID, DateTimeI itime, float val);//B类客户端实现

};

interface ServerAchieve
{

//服务端实现

void AddClient(::Ice::Identity ident, int ctype);
void setPValue(long devID, long pID, float val);
};

};

2）接口实现：

在我的ice定义中

void AddClient(::Ice::Identity ident, int ctype);是很关键的一项，该函数是有服务端实现，

在客户端链接成功将其识别号及类型告知服务端，服务端将进行标记，该逻辑过程如下：

客户端链接及通告服务端代码样例

                Ice::ObjectAdapterPtr adapter = communicator()->createObjectAdapter("");
                Ice::Identity ident;
                ident.name = IceUtil::generateUUID();
                m_strUUID = ident.name;
                ident.category = "";
               ClientAchievePtr crtwoway = new ClientAchieveI(this);
                adapter->add(crtwoway, ident);
               adapter->activate();
                soneway->ice_getConnection()->setAdapter(adapter);
                soneway->AddClient(ident，ctype);//通知服务端

而在服务端，我们将进行标记每个客户端,示例代码：

void ServerAchieveI::AddClient(const ::Ice::Identity& ident,const ::Ice::Int &ctype, const ::Ice::Current& current)
{
printf("adding client `%s(%d)'n", _communicator->identityToString(ident).c_str(),ctype);
TestIce::ClientAchievePrx client = PCS::ClientAchievePrx::uncheckedCast(current.con->createProxy(ident));

//clients定义了一个客户端管理类，采用std::map<TestIce::ClientAchievePrx, ClientFlag> _clients;进行客户端标记

clients->addCLient(client,ctype);
};

现在我们展示服务端接口代码示例：

class ClientManageThread;

class ServerAchieveI : public TestIce::ServerAchieve
{
public:
   ServerAchieveI(const Ice::CommunicatorPtr& communicator);
   virtual ~ServerAchieveI();
   //
   virtual void AddClient(const ::Ice::Identity&, const ::Ice::Int &ctype,const ::Ice::Current& = ::Ice::Current());
    virtual void setPValue(::Ice::Long devID, ::Ice::Long pID, float val, const ::Ice::Current&);
private:
   // Required to prevent compiler warnings with MSVC++
   ServerAchieveI& operator=(const ServerAchieveI&);

   Ice::CommunicatorPtr _communicator;
   ClientManageThread *clients;
};

/
ServerAchieveI::ServerAchieveI(const Ice::CommunicatorPtr& communicator)
   : _communicator(communicator)
{
   clients = new ClientManageThread();
   clients->start();
};

ServerAchieveI::~ServerAchieveI()
{
   try
   {
       delete clients;
       clients = NULL;
   }
   catch (...)
   {

   }
};

void ServerAchieveI::AddClient(const ::Ice::Identity& ident, const ::Ice::Int &ctype,const ::Ice::Current& current)
{
      printf("adding client `%s(%d)'n", _communicator->identityToString(ident).c_str(),ctype);
   TestIce::ClientAchievePrx client = TestIce::ClientAchievePrx::uncheckedCast(current.con->createProxy(ident));
   clients->addCLient(client,ctype);//clients根据ctype类型调用TestIce::ClientAchievePrx的客户端实现函数发送数据到指定客户端
};
//客户端调用该函数实现客户端到服务端的数据发送，soneway->setPValue(devID,pID,val);
void ServerAchieveI::setPValue(::Ice::Long devID, ::Ice::Long pID, float val, const ::Ice::Current& )
{
   std::cerr << " setPValue:"<< devID<<","<<pID<<","<<val << std::endl;
   PFrom _pfrom;
};

展示客户端代码样例，例如该客户端只需实现A类型函数：

///h

class TestIceClient;

class ClientAchieveI : public TestIce::ClientAchieve
{
public:
   ClientAchieveI(TestIceClient* _client);
    ~ClientAchieveI();
    virtual void PValueChange_A(::Ice::Long devID
                              ,::Ice::Long pID
                              , const ::TestIce::DateTimeI& itime
                              , ::Ice::Float val
                              , const ::Ice::Current&);
private:
   TestIceClient* client;//真正实现类
};

/cpp/

ClientAchieveI::ClientAchieveI(TestIceClient* _client) : client(_client)
{
};

ClientAchieveI::~ClientAchieveI()
{

};

void ClientAchieveI::PValueChange(::Ice::Long devID
                              ,::Ice::Long pID
                              , const ::TestIce::DateTimeI& itime
                              , ::Ice::Float val
                              , const ::Ice::Current&)
{

std::cerr <<" PValueChange:" <<devID<<","<<pID<<","<<val<<","<<itime.isec<<","<<itime.imsec<< std::endl;

if(client)
client->PValueChange(devID,pID,itime,val);
};

3）实现调用示例：

在我的ClientManageThread类中，实现数据从服务端发送各客户端：

            mutex_client.Lock();
           std::map<TestIce::ClientAchievePrx, int>::iterator itw = _clients.begin();
           while(itw != _clients.end())
           {
               try
               {

                   switch(it->second)
                   {
                       case 1:
                           itw->first->PValueChange_A(wdlc.devID, wdlc.pID, _itime, wdlc.val);
                       break;
                       case 2:
                           itw->first->PValueChange_B(wdlc.devID, wdlc.pID, _itime, wdlc.val);
                       break;
                       default:
                       break;
                   }
                   itw++;
               }
               catch (...)
               {
                   printf("PValueChange Error:%dn",static_cast<int>(time(NULL)));
#ifdef WIN32
                   itw = _clients.erase(itw);
#else
                   std::map<TestIce::ClientAchievePrx, int>::iterator ittmp = itw++;
                   _clients.erase(ittmp);
#endif
               }
           }
           mutex_client.Unlock();

在客户端调用与已很多zeroc-ice的demoo一致：

//TestIce::ServerAchievePrx soneway;

    if(connect())
    {
        try{            soneway->setPValue(devID,pID,val);
        }catch(...)
        {
            disconnect();
        }
    }

本文只是抛出一个zeroc-ice做全双工通信的思路，所展示代码只是具体代码中择取的代码，功能并不完善，大家可按自身需求修改完善适合自身项目诉求