別人封裝的socket

本文轉載自查看原文 2012-06-15 00:42 6181 tcp/ udp/ socket/ c/c++

一個洋文寫的封裝socket類，因為英語很搓，所以就用google簡單的給翻譯了下。

轉載源：http://www.adp-gmbh.ch/win/misc/sockets.html

socket.h

#ifndef SOCKET_H
#define SOCKET_H

#include <WinSock2.h>

#include <string>

enum TypeSocket {BlockingSocket, NonBlockingSocket};

class Socket 
{
public:

    virtual ~Socket();
    Socket(const Socket&);
    Socket& operator=(Socket&);

    std::string ReceiveLine();
    std::string ReceiveBytes();

    void   Close();

    // The parameter of SendLine is not a const reference
    // because SendLine modifes the std::string passed.
    //參數SendLine不是一個const引用
    //因為SendLine modifes的std :: string傳遞。
    void   SendLine (std::string);

    // The parameter of SendBytes is a const reference
    // because SendBytes does not modify the std::string passed 
    // (in contrast to SendLine).
    //參數SendBytes的是一個const引用
    //，因為SendBytes不修改通過的std :: string
    //（在對比SendLine）。
    void   SendBytes(const std::string&);

protected:
    friend class SocketServer;
    friend class SocketSelect;

    Socket(SOCKET s);
    Socket();


    SOCKET s_;

    int* refCounter_;

private:
    static void Start();
    static void End();
    static int  nofSockets_;
};

class SocketClient : public Socket 
{
public:
    SocketClient(const std::string& host, int port);
};

class SocketServer : public Socket 
{
public:
    SocketServer(int port, int connections, TypeSocket type=BlockingSocket);

    Socket* Accept();
};

// http://msdn.microsoft.com/library/default.asp?url=/library/en-us/winsock/wsapiref_2tiq.asp
class SocketSelect 
{
public:
    SocketSelect(Socket const * const s1, Socket const * const s2=NULL, TypeSocket type=BlockingSocket);

    bool Readable(Socket const * const s);

private:
    fd_set fds_;
}; 



#endif

socket.cpp

#include "Socket.h"
#include <iostream>

using namespace std;

int Socket::nofSockets_= 0;

void Socket::Start() 
{
    if (!nofSockets_) 
    {
        WSADATA info;
        if (WSAStartup(MAKEWORD(2,0), &info)) 
        {
            throw "Could not start WSA";
        }
    }
    ++nofSockets_;
}

void Socket::End() 
{
    WSACleanup();
}

Socket::Socket() : s_(0) 
{
    Start();
    // UDP: use SOCK_DGRAM instead of SOCK_STREAM
    s_ = socket(AF_INET,SOCK_STREAM,0);

    if (s_ == INVALID_SOCKET) 
    {
        throw "INVALID_SOCKET";
    }

    refCounter_ = new int(1);
}

Socket::Socket(SOCKET s) : s_(s) 
{
    Start();
    refCounter_ = new int(1);
};

Socket::~Socket() 
{
    if (! --(*refCounter_)) 
    {
        Close();
        delete refCounter_;
    }

    --nofSockets_;
    if (!nofSockets_) End();
}

Socket::Socket(const Socket& o) 
{
    refCounter_=o.refCounter_;
    (*refCounter_)++;
    s_  =o.s_;

    nofSockets_++;
}

Socket& Socket::operator=(Socket& o) 
{
    (*o.refCounter_)++;

    refCounter_=o.refCounter_;
    s_ =o.s_;

    nofSockets_++;

    return *this;
}

void Socket::Close() 
{
    closesocket(s_);
}

std::string Socket::ReceiveBytes() 
{
    std::string ret;
    char buf[1024];

    while (1) 
    {
        u_long arg = 0;
        if (ioctlsocket(s_, FIONREAD, &arg) != 0)
            break;

        if (arg == 0)
            break;

        if (arg > 1024) arg = 1024;

        int rv = recv (s_, buf, arg, 0);
        if (rv <= 0) break;

        std::string t;

        t.assign (buf, rv);
        ret += t;
    }

    return ret;
}

std::string Socket::ReceiveLine() 
{
    std::string ret;
    while (1) 
    {
        char r;

        switch(recv(s_, &r, 1, 0)) 
        {
      case 0: // not connected anymore;
          // ... but last line sent
          // might not end in \n,
          // so return ret anyway.
          return ret;
      case -1:
          return "";
          //      if (errno == EAGAIN) {
          //        return ret;
          //      } else {
          //      // not connected anymore
          //      return "";
          //      }
        }

        ret += r;
        if (r == '\n')  return ret;
    }
}

void Socket::SendLine(std::string s) 
{
    s += '\n';
    send(s_,s.c_str(),s.length(),0);
}

void Socket::SendBytes(const std::string& s) 
{
    send(s_,s.c_str(),s.length(),0);
}

SocketServer::SocketServer(int port, int connections, TypeSocket type) 
{
    sockaddr_in sa;

    memset(&sa, 0, sizeof(sa));

    sa.sin_family = PF_INET;             
    sa.sin_port = htons(port);          
    s_ = socket(AF_INET, SOCK_STREAM, 0);
    if (s_ == INVALID_SOCKET) {
        throw "INVALID_SOCKET";
    }

    if(type==NonBlockingSocket) {
        u_long arg = 1;
        ioctlsocket(s_, FIONBIO, &arg);
    }

    /* bind the socket to the internet address */
    if (bind(s_, (sockaddr *)&sa, sizeof(sockaddr_in)) == SOCKET_ERROR) {
        closesocket(s_);
        throw "INVALID_SOCKET";
    }

    listen(s_, connections);                               
}

Socket* SocketServer::Accept() 
{
    SOCKET new_sock = accept(s_, 0, 0);
    if (new_sock == INVALID_SOCKET) 
    {
        int rc = WSAGetLastError();
        if(rc==WSAEWOULDBLOCK) 
        {
            return 0; // non-blocking call, no request pending
        }
        else 
        {
            throw "Invalid Socket";
        }
    }

    Socket* r = new Socket(new_sock);
    return r;
}

SocketClient::SocketClient(const std::string& host, int port) : Socket() 
{
    std::string error;

    hostent *he;
    if ((he = gethostbyname(host.c_str())) == 0) 
    {
        error = strerror(errno);
        throw error;
    }

    sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(port);
    addr.sin_addr = *((in_addr *)he->h_addr);
    memset(&(addr.sin_zero), 0, 8); 

    if (::connect(s_, (sockaddr *) &addr, sizeof(sockaddr))) 
    {
        error = strerror(WSAGetLastError());
        throw error;
    }
}

SocketSelect::SocketSelect(Socket const * const s1, Socket const * const s2, TypeSocket type) 
{
    FD_ZERO(&fds_);
    FD_SET(const_cast<Socket*>(s1)->s_,&fds_);
    if(s2) 
    {
        FD_SET(const_cast<Socket*>(s2)->s_,&fds_);
    }     

    TIMEVAL tval;
    tval.tv_sec  = 0;
    tval.tv_usec = 1;

    TIMEVAL *ptval;
    if(type==NonBlockingSocket) 
    {
        ptval = &tval;
    }
    else 
    { 
        ptval = 0;
    }

    if (select (0, &fds_, (fd_set*) 0, (fd_set*) 0, ptval) == SOCKET_ERROR) 
        throw "Error in select";
}

bool SocketSelect::Readable(Socket const* const s) 
{
    if (FD_ISSET(s->s_,&fds_)) return true;
    return false;
}

一個簡單的客戶端
下面這個簡單的客戶端連接到www.google.ch並得到其前面的網站：

#include "Socket.h"

#include <iostream>

using namespace std;

int main() 
{

    try 
    {
        SocketClient s("www.google.com", 80);

        s.SendLine("GET / HTTP/1.0");
        s.SendLine("Host: www.google.com");
        s.SendLine("");

        while (1) 
        {
            string l = s.ReceiveLine();
            if (l.empty()) break;
            cout << l;
            cout.flush();
        }

    } 
    catch (const char* s) 
    {
        cerr << s << endl;
    } 
    catch (std::string s) 
    {
        cerr << s << endl;
    } 
    catch (...) 
    {
        cerr << "unhandled exception\n";
    }

    return 0;
}

一個簡單的echo服務器
以下簡單的服務器上打開2000端口，並等待傳入的連接。每個連接與寫（呼應）同一行的回答。如果你想測試的服務器，使用telnet本地主機2000

/* 
EchoServer.cpp

Copyright (C) 2002-2004 René Nyffenegger

This source code is provided 'as-is', without any express or implied
warranty. In no event will the author be held liable for any damages
arising from the use of this software.

Permission is granted to anyone to use this software for any purpose,
including commercial applications, and to alter it and redistribute it
freely, subject to the following restrictions:

1. The origin of this source code must not be misrepresented; you must not
claim that you wrote the original source code. If you use this source code
in a product, an acknowledgment in the product documentation would be
appreciated but is not required.

2. Altered source versions must be plainly marked as such, and must not be
misrepresented as being the original source code.

3. This notice may not be removed or altered from any source distribution.

René Nyffenegger rene.nyffenegger@adp-gmbh.ch
*/


#include "Socket.h"
#include <process.h>
#include <string>

unsigned __stdcall Answer(void* a) 
{
    Socket* s = (Socket*) a;

    while (1) 
    {
        std::string r = s->ReceiveLine();
        if (r.empty()) break;
        s->SendLine(r);
    }

    delete s;

    return 0;
}

int main(int argc, char* argv[]) 
{
    SocketServer in(2000,5);

    while (1) 
    {
        Socket* s=in.Accept();

        unsigned ret;
        _beginthreadex(0,0,Answer,(void*) s,0,&ret);
    }

    return 0;
}

使用Socket類的代理
您需要編譯這個代理變色龍類。用法：的代理<port proxy><addr服務器><port服務器>。
此代理將聽取<port proxy>每當它接收到一個連接器，繼電器<port<addr服務器>服務器>交通。這使得它非常適合看什么一個SMTP服務器，或同等NNTP客戶端的交流與NNTP服務器的SMTP客戶端交流。

/* 
Proxy.cpp

Copyright (C) 2002-2004 René Nyffenegger

This source code is provided 'as-is', without any express or implied
warranty. In no event will the author be held liable for any damages
arising from the use of this software.

Permission is granted to anyone to use this software for any purpose,
including commercial applications, and to alter it and redistribute it
freely, subject to the following restrictions:

1. The origin of this source code must not be misrepresented; you must not
claim that you wrote the original source code. If you use this source code
in a product, an acknowledgment in the product documentation would be
appreciated but is not required.

2. Altered source versions must be plainly marked as such, and must not be
misrepresented as being the original source code.

3. This notice may not be removed or altered from any source distribution.

René Nyffenegger rene.nyffenegger@adp-gmbh.ch
*/

#include "Socket.h"

#include <iostream>
#include <process.h>
#include <sstream>

int         portProxy;
std::string addrServer;
int         portServer;

unsigned __stdcall RunProxyThread (void* a) 
{
    Socket*      s = (Socket*) a;
    SocketClient c(addrServer, portServer);

    while (1) 
    {
        SocketSelect sel(s, &c);

        bool still_connected = true;

        if (sel.Readable(s)) 
        {
            std::string bytes = s->ReceiveBytes();
            c.SendBytes(bytes);
            std::cout << "Server: " << bytes << std::endl;
            if (bytes.empty()) still_connected=false;
        }
        if (sel.Readable(&c)) 
        {
            std::string bytes = c.ReceiveBytes();
            s->SendBytes(bytes);
            std::cout << "Client: " << bytes << std::endl;
            if (bytes.empty()) still_connected=false;
        }
        if (! still_connected) 
        {
            break;
        }
    }

    delete s;

    return 0;
}

int main(int argc, char* argv[]) 
{
    if (argc < 4) 
    {
        std::cout << "Usage:" << std::endl;
        std::cout << "  proxy <port proxy> <addr server> <port server>" << std::endl;
        std::cout << std::endl;
        std::cout << "  This proxy will then listen on <port proxy> and whenever it receives" << std::endl;
        std::cout << "  a connection, relays the traffic to the <port server> of <addr server>." << std::endl;
        std::cout << "  This makes it ideal to see what an SMTP Client exchanges with a SMTP Server," << std::endl;
        std::cout << "  or equally what a NNTP client exchanges with an NNTP Server." << std::endl << std::endl;
        return -1;
    }

    std::stringstream s; 

    s<<argv[1]; s>>portProxy; s.clear();

    addrServer=argv[2];

    s<<argv[3]; s>>portServer;

    SocketServer in(portProxy,5);

    while (1) 
    {
        Socket* s=in.Accept();

        unsigned ret;
        _beginthreadex(0, 0, RunProxyThread,(void*) s,0,&ret);
    }

    return 0;
}

另見：提琴手：記錄您的計算機和互聯網之間的所有HTTP流量的HTTP調試代理。提琴手可以讓你觀看的HTTP流量，設置斷點，以及“小提琴”傳入或傳出數據。提琴手的設計是比使用Netmon或跟腱簡單得多。
消息經銷商
消息經銷商是一個服務器偵聽端口2000。任何數量的客戶端可以連接到該服務器。當客戶端發送消息到服務器，服務器將播出這個消息，所有其他客戶端，但不發送消息。

/* 
MsgDistributor.cpp

Copyright (C) 2002-2004 René Nyffenegger

This source code is provided 'as-is', without any express or implied
warranty. In no event will the author be held liable for any damages
arising from the use of this software.

Permission is granted to anyone to use this software for any purpose,
including commercial applications, and to alter it and redistribute it
freely, subject to the following restrictions:

1. The origin of this source code must not be misrepresented; you must not
claim that you wrote the original source code. If you use this source code
in a product, an acknowledgment in the product documentation would be
appreciated but is not required.

2. Altered source versions must be plainly marked as such, and must not be
misrepresented as being the original source code.

3. This notice may not be removed or altered from any source distribution.

René Nyffenegger rene.nyffenegger@adp-gmbh.ch
*/

#include "Socket.h"
#include <process.h>
#include <string>
#include <list>

typedef std::list<Socket*> socket_list;

socket_list g_connections;

unsigned __stdcall Connection(void* a) 
{
    Socket* s = (Socket*) a;

    g_connections.push_back(s);

    s->SendLine("Welcome to the Message Distributor");

    while (1) 
    {
        std::string r = s->ReceiveLine();
        if (r.empty()) break;

        for (socket_list::iterator os =g_connections.begin();
            os!=g_connections.end(); 
            os++) 
        {
                if (*os != s) (*os)->SendLine(r);
        }
    }

    g_connections.remove(s);

    delete s;

    return 0;
}

int main() 
{
    SocketServer in(2000,5);

    while (1) 
    {
        Socket* s=in.Accept();

        unsigned ret;
        _beginthreadex(0,0,Connection,(void*) s,0,&ret);
    }

    return 0;
}

Download the files

You can download the source code and the exefiles as a zip fileconsisting of

socket.h
Chameleon.h
Chameleon.cpp
EchoServer.cpp
MsgDistributor.cpp
Proxy.cpp
Socket.cpp
EchoServer.exe
Proxy.exe
makefile

I was able to compile the sources with mingw using the supplied makefile.

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 封裝好的socket,拿去用 cross socket接口封裝 C# .NET Socket封裝 C++ Socket 簡單封裝 ACE - 代碼層次及Socket封裝 C# .NET Socket 簡單實用框架，socket組件封裝 Linux socket編程（一）對套接字操作的封裝封裝Socket.BeginReceive/EndReceive以支持Timeout c# socket 框架學習 SocketAsyncEventArgsPool 封裝 web前端socket封裝庫--giraffe