Linux Socket通信 C/S模型

代码片段(8)

[代码] MySocket.h

01#ifndef _MYSOCKET_0623_H
02#define _MYSOCKET_0623_H
03 
04#include <sys/socket.h>
05#include <sys/types.h>
06#include <arpa/inet.h>
07#include <netinet/in.h>
08#include <sys/wait.h>
09#include <unistd.h>
10#include <iostream>
11#include <string.h>
12#include <stdlib.h>
13 
14//Base class Socket
15class Socket
16{
17public:
18    Socket();
19    virtual ~Socket();
20    bool Create();
21    bool Bind(const unsigned short port);
22    bool Listen() const;
23    bool Accept(Socket &new_sock) const;
24    bool Connect(std::string host, const unsigned short port);//client
25    bool Send(const std::string s) const;
26    int Recv(std::string &s) const;
27    void Close();
28    bool IsValid() const;
29 
30private:
31    int m_sock;
32    sockaddr_in m_addr;
33};
34 
35//ServerSocket, Use Socket as a service
36class ServerSocket : private Socket
37{
38 public:
39  ServerSocket(){Create();}     //for normal data-exchange socket
40  ServerSocket(unsigned short port);    //for listen socket
41  virtual ~ServerSocket();
42  void Accept(ServerSocket &new_sock) const;
43  void Close();
44  const ServerSocket& operator << (const std::string&) const;
45  const ServerSocket& operator >> (std::string&) const;
46};
47 
48//ClientSocket derived form Socket
49class ClientSocket : private Socket
50{
51public:
52    ClientSocket(){Create();}
53    ClientSocket(std::string host, const unsigned short port);
54    virtual ~ClientSocket();
55    void Close();
56    const ClientSocket& operator << (const std::string&) const;
57    const ClientSocket& operator >> (std::string&) const;
58};
59 
60//SocketException
61class SocketException
62{
63public:
64    SocketException(std::string msg = std::string("Socket Exception")): m_msg(msg){}
65    void Print(){std::cout << m_msg << std::endl;}
66private:
67    const std::string m_msg;
68     
69};
70#endif

[代码] MySocket.cpp

001#include "MySocket.h"
002#include <assert.h>
003using namespace std;
004//Implement of Socket class
005 
006static void Trace(const string& msg = "Socket Class Error")
007{
008#ifdef DEBUG
009    cout << msg << endl;
010#endif
011}
012 
013Socket::Socket()
014{
015  m_sock = -1;
016  m_addr.sin_family = AF_INET;
017  m_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
018  m_addr.sin_port = htons(8089);
019}
020 
021Socket::~Socket()
022{
023    if (m_sock != -1)   //valid socket
024    {
025        Close();
026    }
027}
028 
029bool Socket::Create()
030{
031  m_sock = socket(AF_INET, SOCK_STREAM, 0);
032  if (m_sock == -1)
033    {
034      Trace("Create Socket Failure");
035      return false;
036    }
037  else
038    {
039      Trace("Create Socket Succeed");
040      return true;
041    }
042}
043 
044bool Socket::Bind(const unsigned short port)
045{
046    assert(m_sock != -1);
047    m_addr.sin_family = AF_INET;
048    m_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
049    m_addr.sin_port = htons(port);
050    int server_len = sizeof( m_addr );
051    if ( bind(m_sock, (struct sockaddr *)& m_addr, server_len) == -1 )
052    {
053        Trace("Server Bind Failure");
054        return false;
055    }
056    else
057    {
058        return true;
059    }
060}
061 
062bool Socket::Listen() const
063{
064    if ( listen(m_sock, 5) == -1 )
065    {
066        Trace("Server Listen Failure");
067        return false;
068    }
069    else
070    {
071        return true;
072    }
073}
074 
075bool Socket::Accept(Socket & new_socket) const//new_socket as a return
076{
077    int len = sizeof( new_socket.m_addr );
078    new_socket.m_sock = accept( m_sock,
079             (struct sockaddr *)& new_socket.m_addr, (socklen_t*)&len );
080    if ( new_socket.m_sock == -1 )
081    {
082        Trace("Server Accept Failure");
083        return false;
084    }
085    else
086    {
087        return true;
088    }
089}
090 
091bool Socket::Connect(const std::string host, const unsigned short port)
092{
093    assert(m_sock != -1);
094    m_addr.sin_family = AF_INET;
095    m_addr.sin_addr.s_addr = inet_addr(host.c_str());
096    m_addr.sin_port = htons(port);
097    int len = sizeof(m_addr);
098    int res = connect( m_sock, (struct sockaddr*)& m_addr, len);
099    if(res == -1)
100    {
101        Trace("Client Connect Failure");
102        return false;
103    }
104    return true;
105}
106 
107bool Socket::Send(const std::string send_str) const
108{
109    //copy the send_str to a buffer so that we can send it.
110    size_t len = send_str.size() + 1;
111    char *send_buf = NULL;
112    send_buf = new char[len];
113    if (NULL == send_buf)
114    {
115        Trace("Socket: memory allocation failed in Send()");
116        return false;
117    }
118    char t = send_str[0];
119    int i = 0;
120    while ( t != 0 )
121    {
122        send_buf[i] = t;
123        i++;
124        t = send_str[i];
125    }
126    send_buf[i] = 0;
127    //end of copying string
128    assert(i == len-1);
129 
130    int xoff = 0;
131    int xs = 0;
132    do
133    {
134        xs = write(m_sock, send_buf+xoff, len-xoff);
135        if (-1 == xs)
136        {
137            Trace("Socket: send data failed");
138            delete [] send_buf;
139            return false;
140        }
141        else
142        {
143            xoff += xs;
144        }
145    } while(xoff < len);
146    Trace("Socket: send data succeed");
147    delete [] send_buf;
148    return true;   
149}
150 
151int Socket::Recv( std::string & recv_str) const
152{
153    cout << "enter recv" << endl;
154    char *recv_buf;
155    recv_buf = new char[256];
156    memset(recv_buf, 0 ,256);
157    int len = read(m_sock, recv_buf, 256);
158    if (-1 == len)
159    {
160        Trace("Socket: recv data failed");
161        delete [] recv_buf;
162        return -1;
163    }
164    else
165    {
166        recv_str = recv_buf;
167        delete [] recv_buf;
168        return len;
169    }  
170}
171 
172 
173bool Socket::IsValid() const
174{
175  return ( m_sock != -1 );
176}
177 
178void Socket::Close()
179{
180    if (m_sock != -1)
181    {
182        close(m_sock);
183        m_sock = -1;
184    }
185     
186}
187//

[代码] MyClientSocket.cpp

01#include "MySocket.h"
02using namespace std;
03 
04static void Trace(const string& msg = "ServerSocket Class Error")
05{
06#ifdef DEBUG
07    cout << msg << endl;
08#endif
09}
10 
11ClientSocket::ClientSocket(std::string host, const unsigned short port)
12{
13    if ( !Create() )
14    {
15        Trace("Client Socket Constructor Failed");
16        throw SocketException("Client Socket Constructor Failed");
17    }
18    if ( !Connect(host, port) )
19    {
20        throw SocketException("Client Socket Constructor Failed");
21    }
22}
23 
24ClientSocket::~ClientSocket()
25{
26    Close();
27}
28 
29void ClientSocket::Close()
30{
31    Socket::Close();
32}
33 
34const ClientSocket& ClientSocket::operator << (const std::string &s) const
35{
36    if ( !Send(s) )
37    {
38        Trace("Could not write to server socket");
39        throw SocketException("Could not write to client socket");
40    }
41    return *this;
42}
43 
44const ClientSocket& ClientSocket::operator >> (std::string& s) const
45{
46    if ( Recv(s) == -1 )
47    {
48        Trace("Could not read from socket");
49        throw SocketException("Could not read from client socket");
50    }
51    return *this;
52}

[代码] MyServerSocket.cpp

01#include "MySocket.h"
02#include <assert.h>
03using namespace std;
04 
05static void Trace(const string& msg = "ServerSocket Class Error")
06{
07#ifdef DEBUG
08    cout << msg << endl;
09#endif
10}
11 
12ServerSocket::ServerSocket(unsigned short port)
13{
14    if ( !Create() )
15    {
16        Trace("Could not create server socket!");
17        throw SocketException("Could not create : server socket!");
18    }
19    if ( !Bind(port) )
20    {
21        Trace("Could not bind to port!");
22        throw SocketException("Could not Bind : server socket!");
23    }
24    if ( !Listen() )
25    {
26        Trace("Could not listen to socket");
27        throw SocketException("Could not Litsen : server socket!");
28    }
29}
30 
31ServerSocket::~ServerSocket()
32{
33    Close();
34}
35 
36 
37void ServerSocket::Accept(ServerSocket& new_socket) const
38{
39    if ( !Socket::Accept(new_socket) )
40    {
41        throw SocketException("Server Accept Failed");
42    }
43}
44 
45void ServerSocket::Close()
46{
47    Socket::Close();
48}
49 
50const ServerSocket& ServerSocket::operator << (const std::string& s) const
51{
52    if ( !Send(s) )
53    {
54        Trace("Could not write to server socket");
55        throw SocketException("Could not write to server socket");
56    }
57    return *this;
58}
59 
60const ServerSocket& ServerSocket::operator >> (std::string& s) const
61{
62    int ret = Recv(s);
63    if ( ret == -1 )
64    {
65        Trace("Could not read from server socket");
66        throw SocketException("Could not read form server socket");
67    }
68    return *this;
69}

[代码] ServerTest.cpp

01//Create a server for testing
02#include "MySocket.h"
03#include "Calculator.h"
04using namespace std;
05int main()
06{
07    try
08    {
09        int result;
10        ServerSocket server(30000);
11     
12        string s;
13        while(true)
14        {
15            ServerSocket new_sock;
16            server.Accept( new_sock );
17            while(true)
18            {
19                new_sock >> s;
20                cout << "receive : \t" << s << endl;
21                //Deal with client requests
22                new_sock << s;
23                cout << "send: \t " << s << endl;
24            }
25            new_sock.Close();
26        }
27         
28    }
29    catch(SocketException &e)
30    {
31        cout << "SocketException:\t";
32        e.Print();
33    }
34    catch(...)
35    {
36        cout << "Common Exception" << endl;
37    }
38    return 0;
39}

[代码] ClientTest.cpp

01#include "MySocket.h"
02#include "Calculator.h"
03using namespace std;
04 
05int main()
06{
07    try
08    {
09        ClientSocket client("127.0.0.1",30000);
10        string s = "HELLO";
11     
12        int count = 1;
13        while(count <= 5)
14        {
15            cout << "input a string : " ;
16            cin >> s;
17            cout << "You have input " << s << endl;
18            client << s;
19            cout<< "Send to Socket : "<<s<<'\t'<<count<<endl;
20            client >> s;
21            cout<< "Read from Socket : "<<s<<'\t'<<count<<endl;
22            //sleep(2);
23            s = "HELLO";
24            count++;
25        }
26        client.Close();
27    }
28    catch(SocketException &e)
29    {
30        cout << "SocketException:\t";
31        e.Print();
32    }
33    ///
34     
35    return 0;
36}

[代码] MakeClient

01objects = ClientTest.o MyClientSocket.o MySocket.o Calculator.o mathop.o
02ClientTest.out: $(objects)
03    g++ $(objects) -o ClientTest.out
04ClientTest.o: ClientTest.cpp MySocket.h  Calculator.h
05    g++ -c -g -Wall -pedantic -ansi -DDEBUG -o ClientTest.o ClientTest.cpp
06MyClientSocket.o: MyClientSocket.cpp MySocket.h
07    g++ -c -g -Wall -pedantic -ansi -DDEBUG -o MyClientSocket.o MyClientSocket.cpp
08MySocket.o: MySocket.cpp MySocket.h
09    g++ -c -g -Wall -pedantic -ansi -DDEBUG MySocket.cpp -o MySocket.o
10Calculator.o: Calculator.cpp Calculator.h
11    g++ -g -c -Wall -pedantic -ansi -DDEBUG -o Calculator.o Calculator.cpp
12mathop.o: mathop.cpp mathop.h
13    g++ -g -c -Wall -pedantic -ansi -DDEBUG -o mathop.o mathop.cpp
14.PHONY: clean
15clean:
16    -rm $(objects) ClientTest.out
17    

[代码] MakeServer

01objects = ServerTest.o MyServerSocket.o MySocket.o Calculator.o mathop.o
02ServerTest.out: $(objects)
03    g++ $(objects) -o ServerTest.out
04ServerTest.o: ServerTest.cpp MySocket.h  Calculator.h
05    g++ -c -g -Wall -pedantic -ansi -DDEBUG -o ServerTest.o ServerTest.cpp
06MyServerSocket.o: MyServerSocket.cpp MySocket.h
07    g++ -c -g -Wall -pedantic -ansi -DDEBUG -o MyServerSocket.o MyServerSocket.cpp
08MySocket.o: MySocket.cpp MySocket.h
09    g++ -c -g -Wall -pedantic -ansi -DDEBUG MySocket.cpp -o MySocket.o
10Calculator.o: Calculator.cpp Calculator.h
11    g++ -g -c -Wall -pedantic -ansi -DDEBUG -o Calculator.o Calculator.cpp
12mathop.o: mathop.cpp mathop.h
13    g++ -g -c -Wall -pedantic -ansi -DDEBUG -o mathop.o mathop.cpp
14.PHONY: clean
15clean:
16    -rm $(objects) ServerTest.out
17    

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/445183.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Java多线程——基本概念

Java多线程——基本概念

线程和多线程 程序&#xff1a;是一段静态的代码&#xff0c;是应用软件执行的蓝本 进程&#xff1a;是程序的一次动态执行过程&#xff0c;它对应了从代码加载、执行至执行完毕的一个完整过程&#xff0c;这个过程也是进程本身从产生、发展至消亡的过程 线程&#xff1a;是比…
阅读更多...
textCNN初探

textCNN初探

文章目录目录1.什么是textCNN1.1 textCNN 提出的背景1.2 textCNN 合理性分析2.textCNN相比于传统图像领域的CNN有什么特点&#xff1f;3.textCNN例子讲解3.1 参数和超参数3.2 textCNN的数据3.3 textCNN的网络结构定义3.4 代码目录 1.什么是textCNN 1.1 textCNN 提出的背景 我…
阅读更多...
Python(28)-异常

Python(28)-异常

异常1.抛出异常2.捕获异常3.依据错误类型捕获异常4.捕获未知错误5.异常捕获的完整语法6.异常传递7.主动抛出异常本系列博文来自学习《Python基础视频教程》笔记整理&#xff0c;视屏教程连接地址&#xff1a;http://yun.itheima.com/course/273.html1.抛出异常 抛出异常&#…
阅读更多...
词嵌入初探

词嵌入初探

文章目录目录1.词嵌入产生的背景1.1 NLP关键&#xff1a;语言的表示1.2 NLP词的表示方法类型1.2.1 独热表示one-hot1.2.2 词的分布式表示distributed representation1.3 NLP中的语言模型1.4 词的分布表示1.4.1 基于矩阵的分布表示1.4.2 基于聚类的分布表示1.4.3 基于神经网络的…
阅读更多...
Pytorch(5)-梯度反向传播

Pytorch(5)-梯度反向传播

自动求梯度1. 函数对自变量x求梯度--ax^2b2. 网络对参数w求梯度- loss(w,x)3. 自动求梯度的底层支持--torch.autograd3.1 Variable3.1.1 Variable构造函数3.1.2 Variable链式求导--backward()3.1.3 Variable反向传播函数--grad_fn3.2 计算图3.2.1 动态创建计算图3.2.2 非叶子节…
阅读更多...
VIM使用系列之一——配置VIM下编程和代码阅读环境

VIM使用系列之一——配置VIM下编程和代码阅读环境

作者&#xff1a;gnuhpc from http://blog.csdn.net/gnuhpc http://gnuhpc.wordpress.com/ 本文环境&#xff1a;ubuntu 10.10/vim7.2 前言&#xff1a;一年前写过一篇关于VIM的C/C编程环境的文字&#xff0c;一年中又接触了很多东西&#xff0c;深入使用中发现其实还是需要有…
阅读更多...
fastText初探

fastText初探

目录&#xff1a;1、应用场景2、优缺点3、FastText的原理4、FastText词向量与word2vec对比 目录&#xff1a; 1、应用场景 fastText是一种Facebook AI Research在16年开源的一个文本分类器。 其特点就是fast。相对于其它文本分类模型&#xff0c;如SVM&#xff0c;Logistic …
阅读更多...
mpiBlast安装详解以及使用说明

mpiBlast安装详解以及使用说明

Getting mpiblast 现在下载包文件&#xff1a; wget http://www.mpiblast.org/downloads/files/mpiBLAST-1.6.0-pio.tgz 解压包文件&#xff1a; tar xvzf mpiBLAST*.tgz 然后下载ncbi&#xff1a; wget ftp://ftp.ncbi.nih.gov/toolbox/ncbi_tools/old/20061015/ncbi.tar.gz…
阅读更多...
Pytorch(6)-设置随机种子，复现模型结果

Pytorch(6)-设置随机种子，复现模型结果

设置随机种子&#xff0c;复现模型结果1.Python本身的随机因素2.numpy随机因素3.pytorch随机因素在很多情况下&#xff0c;我们希望能够复现实验的结果。为了消除程序中随机因素的影响&#xff0c;我们需要将随机数的种子固定下来。将所有带随机因素的种子全部固定下来后&#…
阅读更多...
如何让自己学习？

如何让自己学习？

阶段性反馈机制&#xff08;如何持之以恒、让自己发疯&#xff09; 反馈机制是王者荣耀的核心武器&#xff0c;击杀野怪获得金币&#xff0c;不断地努力&#xff0c;获得奖励是我们不断的玩这个游戏的主要原因&#xff0c;也是人的本能&#xff0c;我什么都得不到凭什么这么做&…
阅读更多...
追女孩子必备

追女孩子必备

当然&#xff0c;首先要知道女孩子的手机号码。 其次&#xff0c;要对她有兴趣啦。 发个短信&#xff1a;“上次跟你聊天很愉快&#xff0c;能否再次邀你出来聊聊天&#xff1f;” 注意&#xff1a;女孩子答应的话&#xff0c;要找的地点是个比较清静的酒吧&#xff0c;暂时别去…
阅读更多...
python中使用“if __name__ == '__main__'”语句的作用

python中使用“if __name__ == '__main__'”语句的作用

首先用最简洁的语言来说明一下 if __name__ __main__: 的作用&#xff1a;防止在被其他文件导入时显示多余的程序主体部分。 先举个例子&#xff0c;如果不用if __name__ __main__: 会发生什么事&#xff1a; 首先在yy.py中调用cs.py #yy.pyimport csprint(引用cs)cs.cs()p…
阅读更多...
bishi

bishi

鄙视 2011-04-26 20:43:02| 分类&#xff1a;默认分类 |字号订阅腾讯笔试题&#xff1a;const的含义及实现机制 const的含义及实现机制&#xff0c;比如&#xff1a;const int i,是怎么做到i只可读的&#xff1f; const用来说明所定义的变量是只读的。 这些在编译期间完成&…
阅读更多...
NLP复习资料(1)-绪论、数学基础

NLP复习资料(1)-绪论、数学基础

NLP复习资料-绪论、数学基础1.绪论2.数学基础2.1信息论基础&#xff1a;2.2应用实例&#xff1a;词汇消歧国科大&#xff0c;宗老师《自然语言处理》课程复习笔记&#xff0c;个人整理&#xff0c;仅供参考。1.绪论 1&#xff0e; 语言学、计算语言学、自然语言理解、自然语言…
阅读更多...
redis——sentinel

redis——sentinel

什么是哨兵机制 Redis的哨兵(sentinel) 系统用于管理/多个 Redis 服务器,该系统执行以下三个任务: 监控: 哨兵(sentinel) 会不断地检查你的Master和Slave是否运作正常。 提醒:当被监控的某个 Redis出现问题时, 哨兵(sentinel) 可以通过 API 向管理员或者其他…
阅读更多...
珍藏

珍藏

http://www.cnblogs.com/leoo2sk/archive/2011/04/19/nginx-module-develop-guide.html http://ldl.wisplus.net/page/6/
阅读更多...
FM,FFM及其实现

FM,FFM及其实现

在推荐系统和计算广告业务中&#xff0c;点击率CTR&#xff08;click-through rate&#xff09;和转化率CVR&#xff08;conversion rate&#xff09;是衡量流量转化的两个关键指标。准确的估计CTR、CVR对于提高流量的价值&#xff0c;增加广告及电商收入有重要的指导作用。业界…
阅读更多...
linux-在cenos上安装大全(nginx/JRE/maven/Tomcat/MYSQL/redis/kafka/es...)

linux-在cenos上安装大全(nginx/JRE/maven/Tomcat/MYSQL/redis/kafka/es...)

云服务器 阿里云 腾讯云 七牛云 百度云 天翼云 华为云 西部数码 自己购买一个&#xff0c;学生和企业用户都有优惠的。 putty 自己下载一个putty&#xff0c;用来操作云服务器。 putty.org 一路下一步就ok。 点击putty.exe,输入你的ip或域名 最好改成20&#xff1…
阅读更多...
NLP复习资料(2)-三~五章：形式语言、语料库、语言模型

NLP复习资料(2)-三~五章：形式语言、语料库、语言模型

NLP复习资料-三~五章1.第三章&#xff1a;形式语言2.第四章&#xff1a;语料库3.第五章&#xff1a;语言模型国科大&#xff0c;宗老师《自然语言处理》课程复习笔记&#xff0c;个人整理&#xff0c;仅供参考。1.第三章&#xff1a;形式语言 1.语言描述的三种途径&#xff1a…
阅读更多...
存储管理的页面置换算法

存储管理的页面置换算法

存储管理的页面置换算法 存储管理的页面置换算法在考试中常常会考到&#xff0c;操作系统教材中主要介绍了3种常用的页面置换算法&#xff0c;分别是&#xff1a;先进先出法&#xff08;FIFO&#xff09;、最佳置换法&#xff08;OPT&#xff09;和最近最少使用置换法&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023