C++、python和go語(yǔ)言實(shí)現(xiàn)的簡(jiǎn)單客戶端服務(wù)器代碼示例

2020-01-26 15:09:44

字體：大中小

供稿：網(wǎng)友

工作中用到了C/S模型，所做的也無(wú)非是給服務(wù)器發(fā)數(shù)據(jù)，但開(kāi)發(fā)階段會(huì)遇到程序自身的回環(huán)測(cè)試，需要用到簡(jiǎn)單的服務(wù)端以便驗(yàn)證數(shù)據(jù)發(fā)送的正確性。

寫軟件用C++，跑測(cè)試用python，這段時(shí)間也剛好看go語(yǔ)言，所以都要有demo。以下三組程序?qū)崿F(xiàn)的功能相同，這里一起做下總結(jié)。

一、C++實(shí)現(xiàn)

Boost.Asio是一個(gè)跨平臺(tái)的C++庫(kù)，它用現(xiàn)代C++方法為網(wǎng)絡(luò)和底層I/O程序提供了一致的異步I/O模型。為了跨平臺(tái)，我用boost庫(kù)實(shí)現(xiàn)，具體如下。

服務(wù)端代碼：

復(fù)制代碼代碼如下:

/*
     File      : svr.cpp
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
*/

#include <iostream>
#include <boost/asio.hpp>

using boost::asio::ip::tcp;
enum {max_length = 1024};

typedef boost::shared_ptr<tcp::socket> socket_ptr;

int main()
{
    boost::asio::io_service io_service;
    tcp::acceptor a(io_service, tcp::endpoint(tcp::v4(), atoi("12345")));
    for (;;)
    {
        socket_ptr sock(new tcp::socket(io_service));
        a.accept(*sock);
        char data[max_length];
        boost::system::error_code error;
        size_t length = sock->read_some(boost::asio::buffer(data), error);
        data[length] = 0;
        std::cout<<data<<std::endl;
        sock->close();
    }
    return 0;
}

客戶端代碼：

復(fù)制代碼代碼如下:

/*
     File      : cli.cpp
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
*/
#include <iostream>
#include <boost/asio.hpp>

using boost::asio::ip::tcp;
enum { max_length = 1024 };

int main(int argc, char* argv[])
{
    boost::asio::io_service io_service;
    tcp::resolver resolver(io_service);
    tcp::resolver::query query(tcp::v4(), "127.0.0.1","12345");
    tcp::resolver::iterator iterator = resolver.resolve(query);

tcp::socket s(io_service);
s.connect(*iterator);

    std::cout << "Please input: ";
    char request[max_length];
    std::cin.getline(request, max_length);
    size_t request_length = strlen(request);
    boost::asio::write(s, boost::asio::buffer(request, request_length));
    return 0;
}

編譯：g++ cli.cpp -o cli -lboost_system -lboost_thread-mt

二、python實(shí)現(xiàn)

服務(wù)端代碼：

復(fù)制代碼代碼如下:

'''
     File      : svr.py
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
'''
import socket,os
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  
sock.bind(('127.0.0.1', 12345))  
sock.listen(5)  
while True:  
    connection,address = sock.accept()  
    buf = connection.recv(1024)  
    print buf            
    connection.close()

客戶端代碼：

復(fù)制代碼代碼如下:

'''
     File      : cli.py
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
'''
import socket  
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  
sock.connect(('127.0.0.1', 12345))  
#sock.send('Test/n')  
sock.send(raw_input("Please input : "))  
sock.close()

三、go語(yǔ)言實(shí)現(xiàn)

服務(wù)端代碼：

復(fù)制代碼代碼如下:

/*
     File      : svr.go
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
*/
package main

import(
    "net"
    "fmt"
    "bufio"
)

func main() {
    client,err := net.Listen("tcp","127.0.0.1:12345")
    if err != nil {
        fmt.Printf("Error : %s/n",err.String())
    }
    for {
        if c, err := client.Accept(); err == nil {
            defer c.Close()
            line, _ := bufio.NewReader(c).ReadString('/n')
            fmt.Println(line)
        }
    }
}

客戶端代碼：

復(fù)制代碼代碼如下:

/*
     File      : cli.go
     Author    : Mike
     E-Mail    : Mike_Zhang@live.com
*/
package main

import(
"net"
"fmt"
)

func main() {
    conn, err := net.Dial("tcp", "127.0.0.1:12345")
    if err != nil {
        fmt.Printf("Error : %s/n",err.String())
    }
    conn.Write([]byte("Just a test"))
}

運(yùn)行效果（go語(yǔ)言為例）：