C++ boost::asio::serial_port 串口通信类 使用 封装 [大三四八九月实习]

(1)类头文件

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

usingnamespacestd;
usingnamespaceboost::asio;

typedefstringany_type;

classMySerialPort
{
private:
	//Initializeport
	boolinit_port(constany_typeport,constunsignedintchar_size);
public:
	//Constructor
	//Destructor
MySerialPort(constany_type&port_name);
	~MySerialPort();
	
	//Writesomedatatoport
	voidwrite_to_serial(constany_typedata);

	//Readdatafromportwhichwritedatajustnow
	voidread_from_serial();

	//Theasyanccallbackfunctionofasyanc_read
	voidhandle_read(charbuf[],boost::system::error_codeec,
		std::size_tbytes_transferred);

	//ToCallio_service::runfunctiontocallasyanccallbackfunciton
	voidcall_handle();
	
private:
	//io_serviceObject
	io_servicem_ios;

	//SerialportObject
	serial_port*pSerialPort;

	//Forsavecomname
	any_typem_port;

	//Serial_portfunctionexception
	boost::system::error_codeec;
};

(2)成员函数实现

#include"stdafx.h"
#include<string>
#include<vector>
#include"SerialCom.h"

//DefineConstructorfunction
MySerialPort::MySerialPort(constany_type&port_name):pSerialPort(NULL)
{
pSerialPort=newserial_port(m_ios);
	if(pSerialPort){
		init_port(port_name,8);
	}
}

//Definedestructorfunction
MySerialPort::~MySerialPort()
{
if(pSerialPort)
{
deletepSerialPort;
}
}

//Initializeport
boolMySerialPort::init_port(constany_typeport,constunsignedintchar_size)
{
	//Newnotsuccess
	if(!pSerialPort){
		returnfalse;
	}

//OpenSerialportobject
pSerialPort->open(port,ec);
	

	//Setportargument
	pSerialPort->set_option(serial_port::baud_rate(9600),ec);
	pSerialPort->set_option(serial_port::flow_control(serial_port::flow_control::none),ec);
	pSerialPort->set_option(serial_port::parity(serial_port::parity::none),ec);
	pSerialPort->set_option(serial_port::stop_bits(serial_port::stop_bits::one),ec);
	pSerialPort->set_option(serial_port::character_size(char_size),ec);

	returntrue;
}

//Definewirte_to_serialtowritedatatoserial
voidMySerialPort::write_to_serial(constany_typedata)
{
size_tlen=write(*pSerialPort,buffer(data),ec);
cout<<len<<"\t"<<data<<"\n";
}

voidMySerialPort::handle_read(charbuf[],boost::system::error_codeec,
	std::size_tbytes_transferred)
{
	cout<<"\nhandle_read:";
	cout.write(buf,bytes_transferred);
}

//Readdatafromtheserial
voidMySerialPort::read_from_serial()
{
charv[10];
async_read(*pSerialPort,buffer(v),boost::bind(&MySerialPort::handle_read,this,v,_1,_2));
}

//Callhandle_readfunctionwhenasyncfunctionreadcompleteorcomeoutexception
voidMySerialPort::call_handle()
{
//Therecanusedeadline_timertocancleserial_portreaddata

	//Waitforcallcallbackfunction
	m_ios.run();
}

(3)使用类

//BoostSerialCommunication.cpp:Definestheentrypointfortheconsoleapplication.
//
#ifdef_MSC_VER
#define_WIN32_WINNT0X0501
#endif

#defineBOOST_REGEX_NO_LIB
#defineBOOST_DATE_TIME_SOURCE
#defineBOOST_SYSTEM_NO_LIB

#include"stdafx.h"
#include"SerialCom.h"

int_tmain(intargc,_TCHAR*argv[])
try
{
{
	MySerialPortmy_Sp("COM3");
	my_Sp.write_to_serial("SerialPort");
	my_Sp.read_from_serial();
	my_Sp.call_handle();
	getchar();
}
	getchar();
	return0;
}
catch(std::exception&e)
{
cout<<e.what();
getchar();
}