streambuf定義了對流緩沖區(qū)操作的接口炬转，主要分為輸出緩沖流和輸入緩沖流。streambuf有兩種用法，一是直接使用各個接口馆截，二是繼承并實現(xiàn)新的I/O channels。

1. 輸出緩沖流:

• pbase(): put base或悲，輸出緩沖流的首指針孙咪。
• pptr(): put pointer堪唐，當前可寫位置
• epptr(): end put pointer巡语，輸出緩沖流的尾指針+1，即one past the last character淮菠。

函數(shù)：
setp(char new_pbase, char new_epptr)**
注：設置pbase,pptr,epptr三個指針的位置：

• pbase()=new_pbase;
• pptr()=bew_pbase;
• epptr()=new_epptr;

pbump(int offset)
注： 移動pptr offset個位置男公。當我們寫入num個數(shù)據(jù)，pbump(num)合陵。

overflow
當緩沖區(qū)滿時的操作枢赔；
pptr() == epptr()

2. 輸入緩沖流:

• eback(): 指向輸入緩沖流的首指針
• gptr(): 當前輸入緩沖流的位置
• egptr(): 輸入緩沖流的末尾
• gbump(): 移動gptr
• setg(): 設置eback/gptr/egptr的位置

underflow()
當無緩沖區(qū)數(shù)據(jù)可讀時。
cond: gptr()=egptr()

setg
setg (eback_base,new_gptr, new_egptr)
分別設置：

• eback
• gptr
• egptr

3. 基于streambuf自定義一個輸入輸出緩沖流

prebufferstream.hpp:

/*  Author: zhangwen1@unionpay.com */
/*  Date: 2020-11-24               */

/*
 * Provide Custom Streambufeer Example 
*/ 

#ifndef PREBUFFERSTREAM_HPP
#define PREBUFFERSTREAM_HPP

#include <streambuf>
#include <cstdio>
#include <exception>

class prebuffer: public std::streambuf{

public:
  typedef std::char_traits<char> traits_ty;
  typedef traits_ty::int_type int_type;
  typedef traits_ty::pos_type pos_type;
  typedef traits_ty::off_type off_type;

private:
  int m_mode;
  int m_filedes;

  static const int s_buf_size = 4092;
  static const int s_pback_size = 4;
  char buffer[s_buf_size];

  void init(int fd, int om, bool throw_exception);

  int flushoutput();

public:

  prebuffer(int fd, int om, bool throw_exception=false);
  prebuffer(const prebuffer&)=delete;
  prebuffer& operator=(const prebuffer&)=delete;
  prebuffer(prebuffer&&)=delete;
  prebuffer& operator=(prebuffer&&)=delete;

  ~prebuffer(){close();}

  virtual int_type overflow(int_type c) override;
  virtual int_type underflow() override;

  bool is_open() const { return m_filedes >= 0; }

  void close();
  virtual int sync() override;

  std::string get_str(){
    return std::string(buffer,this->pptr()-buffer);
  }

};


class FileError: public std::exception{
  const char* what(void) const throw(){
    return "Invaild fd";
  }
};

#endif

prebufferstream.cc:

#include "prebufferstream.hpp"

#include <iostream>
#include <unistd.h>
#include <cstring>

void prebuffer::init(int fd, int om, bool throw_exception){
  m_filedes = fd;
  if (m_filedes > 0){
    m_mode = om;
  }
  if (throw_exception && !is_open()){
      throw FileError();
  }
  setg(buffer+s_pback_size,
       buffer+s_pback_size,
       buffer+s_pback_size);
  setp(buffer,
       buffer+s_buf_size-1);
}

prebuffer::prebuffer(int fd, int om, bool throw_exception){
  init(fd,om,throw_exception);
}

void prebuffer::close(){
  if (is_open()){
    this->sync();
    m_mode = 0;
    m_filedes = -1;
  }
}

prebuffer::int_type prebuffer::underflow(){

  if (gptr() < egptr()){
    return static_cast<unsigned char>(*gptr());
  }
  int num_putback=0;
  if (s_pback_size > 0){
    num_putback = gptr()-eback();
    if (num_putback > s_pback_size){
      num_putback = s_pback_size;
    }
    std::memcpy(buffer+s_pback_size-num_putback,gptr()-num_putback,num_putback);
  }

  const int num = ::read(m_filedes,buffer+s_pback_size,s_buf_size-s_pback_size);

  if (num <= 0){return EOF;}
  setg(buffer+s_pback_size-num_putback,buffer+s_pback_size,buffer+s_pback_size+num);

  return static_cast<unsigned char>(*gptr());

}

prebuffer::int_type prebuffer::overflow(int_type c){
  std::cout<<"Overflow Happend"<<std::endl;
  if (!(m_mode & std::ios::out) || !is_open()) return EOF;
  if (c != EOF){
    *pptr() = c;
    pbump(1);
  }
  if (flushoutput() == EOF)
    {
      return -1; 
    }

  return c;
}

int prebuffer::flushoutput(){
  if (!(m_mode & std::ios::out) || !is_open()) return EOF;
  size_t num = pptr()-pbase();
  if (::write(m_filedes,buffer,num) == -1){
    return EOF;
  }
  pbump(-num);
  return num;
}

int prebuffer::sync(){
  if (flushoutput() == EOF){
    return -1;
  }
  return 0;
}

測試, main.cc：

#include "prebufferstream.hpp"
#include <fcntl.h> 
#include <ostream>
#include <istream>
#include <unistd.h>
#include <iostream>

int main(int argc,char* argv[]){

  std::string file_name1 = "test";
  std::string file_name2 = "intest";
  int fdout;
  int fdin;
  if ((fdout=open(file_name1.c_str(),O_RDWR | O_CREAT | O_APPEND)) < 0){
    std::cout<<"ERROR Open File"<<std::endl;
  }
  if ((fdin=open(file_name2.c_str(),O_RDONLY | O_CREAT | O_APPEND)) < 0){
    std::cout<<"ERROR Open File"<<std::endl;
  }


  prebuffer ot{fdout,std::ios::out};
  prebuffer it{fdin,std::ios::in};
  std::ostream dout(&ot);
  std::istream dint(&it);
  dout<<1<<2<<3<<4<<5<<"\n";

  std::cout<<ot.get_str()<<std::endl;

  ot.sync();
  int line;
  while (dint>>line){
    std::cout<<line<<" ";
  }

  close(fdout);
  close(fdin);

  return 0;
}