ACE基本的TCP/IP Socket用法之TCP通信(接收什么就打印什么)1.0

客户端每隔8秒钟向服务端建立连接,发送内容之后关闭连接;

服务端不停的接受客户端的连接请求,收到内容之后就打印出来;

客户端从本地文件中读取内容发送给客户端;

客户端代码:client_main.cpp

#include <iostream>
#include <string>
using namespace std;
#include <fstream>
#include <iterator>

#include "ace/INET_Addr.h"
#include "ace/SOCK_Connector.h"
#include "ace/OS.h"
#include "ace/Log_Msg.h"
#include "ace/Event_Handler.h"
#include "ace/Reactor.h"
#include "ace/Thread_Manager.h"
#include "ace/INET_Addr.h"
#include "ace/SOCK_Stream.h"

class My_Timer_Handler : public ACE_Event_Handler
{
public:
    My_Timer_Handler(const int delay,
        const int interval,
        const ACE_INET_Addr& addr);
    ~My_Timer_Handler();
    int handle_timeout(const ACE_Time_Value& , const void *act /* = 0 */);//计时器到期后执行的回调函数
private:
    void start_timing(void);
    bool send_file(void);
    long time_handle_;//在计时器队列中的ID
    int delay_;
    int interval_;
    ACE_INET_Addr addr_;
    //    ACE_INET_Addr addr(9997,ACE_LOCALHOST);
    ACE_SOCK_Connector connector_;
    ACE_SOCK_Stream peer_;
};

My_Timer_Handler::My_Timer_Handler(const int delay,
    const int interval,
    const ACE_INET_Addr& addr)
    :delay_(delay),interval_(interval),addr_(addr)
{
    cout<<"My_Timer_Handler()"<<endl;
    this->reactor(ACE_Reactor::instance());
    cout<<"start_timing["<<this->delay_<<","<<this->interval_<<"]"<<endl;
    //任务均由计时器触发
    start_timing();
}
void My_Timer_Handler::start_timing(void)
{
    this->time_handle_ = this->reactor()->schedule_timer(this,//在这里注册定时器
        0,
        ACE_Time_Value(this->delay_),//程序一开始延迟delay秒开始首次执行到期函数
        ACE_Time_Value(this->interval_));//循环计时,每隔interval秒重复执行
}

int My_Timer_Handler::handle_timeout(const ACE_Time_Value& , const void *act /* = 0 */)
{
    cout<<"\n\n\n计时器到期,开始查找文件并尝试发送到对端"<<endl;
    char arr[200]={0};
    this->addr_.addr_to_string(arr,sizeof(arr));
    cout<<"TCP开始和对端建立连接:"<<arr<<endl;
    if (this->connector_.connect(this->peer_,this->addr_) == -1)
    {
        cout<<"TCP 连接对端失败"<<endl;
    }
    else
    {
        cout<<"开始发送文件到对端"<<endl;
        if (send_file())
        {
            cout<<"TCP发送文件内容成功"<<endl;
            cout<<"关闭连接"<<endl;
            this->peer_.close();
        }
    }
    return 0;
}

bool My_Timer_Handler::send_file(void)
{
    string file_name("temp_file.xml");
    ifstream fin(file_name);
    istream_iterator<char> iter_begin(fin),iter_end;
    string send_str(iter_begin,iter_end);

    cout<<"发送"<<send_str.size()<<"个字节\n发送内容:"<<endl<<send_str<<endl;
    int send_length = this->peer_.send_n(send_str.c_str(),send_str.size());
    if (send_length == -1)
    {
        cout<<"TCP发送文件内容失败"<<endl;
        return false;
    }
    return true;
}
My_Timer_Handler::~My_Timer_Handler()
{
    cout<<"~My_Timer_Handler()"<<endl;            

    cout<<"cancel_timer(this->time_handle_)"<<endl;
    ACE_Reactor::instance()->cancel_timer(this->time_handle_);
}

int main(int argc, char* argv[])
{
    int delay = 2;
    int interval = 8;
    //ACE_INET_Addr addr("221.226.0.182:9997");
    ACE_INET_Addr server_addr(9997,ACE_LOCALHOST);

    My_Timer_Handler my_handle(delay,interval,server_addr);

    while (true)
    {
        ACE_Reactor::instance()->handle_events();
    }

    return 0;
}

服务端代码:server_main.cpp

#include "ace/INET_Addr.h"
#include "ace/Time_Value.h"
#include "ace/SOCK_Acceptor.h"
#include "ace/SOCK_Stream.h"
#include "ace/Log_Msg.h"
#include "ace/OS.h"

#include <string>
#include <iostream>
using namespace std;

int main(int argc, char* argv[])
{
    ACE_INET_Addr port_to_listen(9997);
    ACE_SOCK_Stream peer;
    ACE_SOCK_Acceptor acceptor;
    if (acceptor.open(port_to_listen,1) == -1)
    {
        ACE_ERROR_RETURN((LM_ERROR,
            ACE_TEXT("%p\n"),
            ACE_TEXT("acceptor.open")),1);
    }
    else
    {
        cout<<"start listen"<<endl;
    }
    ACE_INET_Addr peer_addr;

    char buffer[1024*60]={0};
    ssize_t bytes_received;

    while (true)
    {
        if (acceptor.accept(peer,&peer_addr) == -1)
        {
            cout<<"接受连接失败"<<endl;
        }
        else
        {
            cout<<"连接建立"<<endl;
            const int name_length = 1000;
            char peer_name[name_length]={0};
            peer_addr.addr_to_string(peer_name,name_length);
            cout<<"connect from "<<peer_name<<endl;

            bytes_received = peer.recv(buffer,sizeof(buffer));
            if (bytes_received == -1)
            {
                cout<<"socket not exist"<<endl;
                peer.close();
            }
            else if (bytes_received == 0)
            {
                cout<<"socket closed"<<endl;
                peer.close();
            }
            else
            {
                string str(buffer,bytes_received);
                cout<<"收到的报文长度: "<<bytes_received<<endl
                    <<"收到的内容: \n"<<str<<endl<<"\n\n\n";
            }
            ACE_Time_Value t(0,1000);
            ACE_OS::sleep(t);
        }
    }
    return 0;
}

输出:

时间: 09-18

ACE基本的TCP/IP Socket用法之TCP通信(接收什么就打印什么)1.0的相关文章

http tcp/ip socket

这两天重新看了下TCP/IP的基本概念,也重新看了下http协议,分别是<TCP/IP详解卷1:协议>和<Http:The Definitive Guide>这两本书. 看完后有两点感触: (1)基础的理论知识对工作还是有很大帮助.平时工作中,也许我们更多的关注问题怎么解决,而解决问题有多种方式,其中,来的快的就是百度或Android官网的开发文档,这两种方式基本能解决工作中的所有技术问题,且直接告诉你解决问题的方式(步骤或code直接上),这是互联网化知识共享的体现.而很多时候,

mysql错误:Can’t create TCP/IP socket (10106)

昨天晚上十一点半,有个女同学打电话说电脑出问题了,说tomcat和mysql打不开了,各种急!因为后天就要答辩了,这些软件打不开,系统也就运行不起来!大半夜的让我怎么办,只好说明天早起帮看看! 早早的起来了,接过同学的电脑!回到宿舍看了一下,mysql果然打不开报了这样的错误"mysql错误:Can't create TCP/IP socket (10106)",目测是socket端口被占用的原因,然后在打开tomcat,报的错误中也包含了"socket",再一次加

转:TCP/IP详解--举例明白发送/接收缓冲区、滑动窗口协议之间的关系

原文地址:http://blog.csdn.net/yusiguyuan/article/details/21439633#1536434-tsina-1-74921-66a1f5d8f89e9ad52626f6f40fdeadaa  TCP/IP详解--举例明白发送/接收缓冲区.滑动窗口协议之间的关系. 一个例子明白发送缓冲区.接受缓冲区.滑动窗口协议之间的关系. 在上面的几篇文章中简单介绍了上述几个概念在TCP网络编程中的关系,也对应了几个基本socket系统调用的几个行为,这里再列举一个例

图解 TCP/IP 第六章 TCP与UDP 笔记6.1 传输层的作用

?图解?TCP/IP? 第六章?TCP与UDP? ?笔记6.1 传输层的作用 ? 传输层必须指出这个具体的程序,为了实现这一功能,使用端口号这样一种识别码.根据端口号,就可以识别在传输层上一层的应用程序所有进行处理的具体程序. ? 6.1.1 传输层定义 6.1.2 通信处理 ? 6.1.3 两种传输层协议 TCP和UDP TCP 是面向连接的.可靠的流协议.流就是指不间断的数据结构,你可以把它想象成排水管道中的水流. UDP 是不具有可靠性的数据包协议 .细微的处理会交给上层的应用去完成.在U

TCP/IP解析(一):TCP/IP的工作方式

本文包含以下内容: 1.TCP/IP协议系统 2.OSI模型 3.数据包 4.TCP/IP的交互方式 1.TCP/IP模型的协议层 分为四层: 网络访问层:提供与物理网络连接的接口.根据硬件的物理地址实现数据寻址. 网际层:提供独立于硬件的逻辑寻址. 传输层:为网络提供流量控制.错误控制和确认服务,充当网络应用程序的接口. 应用层:为文件传输.远程控制等提供应用程序. OSI七层模型 物理层:把数据转换为传输介质上的电子流或模拟脉冲,并监视数据的传输. 数据链路层:提供与网络适配器相连的接口,维

Android TCP/IP Socket Test

TCP/IP协议:Transmission Control Protocol/Internet Protocol的简写,中译名为传输控制协议/因特网互联协议,又名网络通讯协议,是Internet最基本的协议.Internet国际互联网络的基础,由网络层的IP协议和传输层的TCP协议组成.TCP/IP 定义了电子设备如何连入因特网,以及数据如何在它们之间传输的标准.协议采用了4层的层级结构,每一层都呼叫它的下一层所提供的网络来完成自己的需求.通俗而言:TCP负责发现传输的问题,一有问题就发出信号,

一个项目看java TCP/IP Socket编程

前一段时间刚做了个java程序和网络上多台机器的c程序通讯的项目,遵循的是TCP/IP协议,用到了java的Socket编程.网络通讯是java的强项,用TCP/IP协议可以方便的和网络上的其他程序互通消息. 先来介绍下网络协议:     TCP/IP         Transmission Control Protocol 传输控制协议         Internet Protocol 互联网协议     UDP         User Datagram Protocol 用户数据协议

TCP/IP Socket 的理解

网络由下往上分为:物理层.数据链路层.网络层.传输层.会话层.表示层和应用层. TCP 协议对应于传输层,HTTP 协议对应应用层,Socket 则是对 TCP/IP 协议的封装. 也可以说 TCP/IP 协议是传输层协议,主要解决数据如何在网络中传输,HTTP 是应用层协议,解决如何包装传输的数据. 实际上 Socket 是对 TCP/IP 协议的封装,Socket 本身并不是协议,而是一个调用接口(API),通过 Scoket 我们才能使用 TCP/IP. 所以说 Socket 的出现只是使

TCP IP SOCKET 笔记

网络由下往上分为 物理层.数据链路层.网络层.传输层.会话层.表示层和应用层. 通过初步的了解,我知道IP协议对应于网络层,TCP协议对应于传输层,而HTTP协议对应于应用层, 三者从本质上来说没有可比性, socket则是对TCP/IP协议的封装和应用(程序员层面上). 也可以说,TPC/IP协议是传输层协议,主要解决数据如何在网络中传输, 而HTTP是应用层协议,主要解决如何包装数据. 关于TCP/IP和HTTP协议的关系,网络有一段比较容易理解的介绍: “我们在传输数据时,可以只使用(传输