~~~
package main
import (
"os"
"fmt"
"io"
"bufio"
"io/ioutil"
"time"
)
func ReadFile1(filename string) {
// os.Create() 和 os.Open() 也是调用了os.OpenFile()
/*
*第二个参数: 文件打开模式
syscall.O_RDONLY // 只读模式打开文件
syscall.O_WRONLY // 只写模式打开文件
syscall.O_RDWR // 读写模式打开文件
syscall.O_APPEND // 写操作时将数据附加到文件尾部
syscall.O_CREAT // 如果不存在将创建一个新文件
syscall.O_EXCL // 和O_CREATE配合使用，文件必须不存在
syscall.O_SYNC // 打开文件用于同步I/O
syscall.O_TRUNC // 如果可能，打开时清空文件
*/
/*第三个参数: 权限控制
-rw-r--r--
- | rw- | r-- | r--
1 | 2 | 3 | 4
1 文件类型
2 拥有者权限
3 群组用户权限
4 其它用户权限
r 可读 4
w 可写 2
x 可执行 1
- 无权限 0
*/
//os.O_WRONLY 只写 O_RDWR 读写 (认错单词, 被坑了)
file, err := os.OpenFile(filename, os.O_RDONLY, 0777)
if err != nil {
fmt.Println(err)
}
defer file.Close()
//var b[]byte 长度为0
var b [64]byte
var content []byte
/*
fmt.Println(reflect.TypeOf(b))
fmt.Println(reflect.TypeOf(b[:]))
*/
for {
n, err := file.Read(b[:])
//读到没有内容时,报错
if err == io.EOF {
break
}
if err != nil {
fmt.Println(err)
}
//content = append(content, b[:]...) //最后可能读不够64字节
content = append(content, b[:n]...)
}
fmt.Println(string(content))
}
func ReadFile2(filename string) {
//带缓冲读取文件
file, err := os.OpenFile(filename, os.O_RDONLY, 0777)
if err != nil {
fmt.Println(err)
}
//*file 实现了 Reader接口
reader := bufio.NewReader(file)
var b [64]byte
var content []byte
for {
//Read有很多读取数据的方法
//reader.ReadString('\n') 读取一行数据
n, err := reader.Read(b[:])
if err == io.EOF {
break
}
if err != nil {
fmt.Println(err)
}
content = append(content, b[:n]...)
}
fmt.Println(string(content))
}
func ReadFile3(filename string) {
//一次性读取整个文件
content, err := ioutil.ReadFile(filename)
if err != nil {
fmt.Println(err)
}
fmt.Println(string(content))
}
func WriteFile1(filename string) {
file, err := os.OpenFile(filename, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0777)
if err != nil {
fmt.Println(err)
}
var b []byte
b = []byte("\nHello World\nHello World2")
_, err = file.Write(b)
if err != nil {
fmt.Println(err)
}
}
func WriteFile2(filename string) {
file, err := os.OpenFile(filename, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0777)
if err != nil {
fmt.Println(err)
}
var b []byte
b = []byte("\nHello World\nHello World23")
write := bufio.NewWriter(file)
n, err := write.Write(b)
//Flush方法将缓冲中的数据写入下层的io.Writer接口
write.Flush()
fmt.Println(n)
if err != nil {
fmt.Println(err)
}
}
func WriteFile3(filename string) {
var b []byte
b = []byte("Hello World\nHello World2")
//写一个全新的文件
//os.O_WRONLY|os.O_CREATE|os.O_TRUNC
err := ioutil.WriteFile(filename, b, 0777)
if err != nil {
fmt.Println(err)
}
}
/*
类型*File
标准输入 Stdin = NewFile(uintptr(syscall.Stdin), "/dev/stdin")
标准输出 Stdout = NemwFile(uintptr(syscall.Stdout), "/dev/stdout")
标准错误 Stderr = NewFile(uintptr(syscall.Stderr), "/dev/stderr")
*/
func ReadAndWrite(filename string) {
//_, err := io.WriteString(os.Stdout, "Hello World")
//if err != nil {
// fmt.Println(err)
//}
/*
Pipe创建一个同步的内存中的管道。它可以用于连接期望io.Reader的代码和期望io.Writer的代码。一端的读取对应另一端的写入，直接在两端拷贝数据，没有内部缓冲。可以安全的并行调用Read和Write或者Read/Write与Close方法。Close方法会在最后一次阻塞中的I/O操作结束后完成。并行调用Read或并行调用Write也是安全的：每一个独立的调用会依次进行。
*/
r, w := io.Pipe()
go func() {
i := 0
for {
w.Write([]byte(fmt.Sprint("Number", i)))
i++
}
}()
go func() {
var d [8]byte
for {
n, err := r.Read(d[:])
if err != nil {
fmt.Println(err)
}
fmt.Println(string(d[:n]))
}
}()
time.Sleep(time.Second * 10)
}
func main() {
var filename = "D:/uploads/file.txt"
ReadAndWrite(filename)
//TODO : ReadFile
//ReadFile1(filename)
//ReadFile2(filename) //带缓冲读取文件
//ReadFile3(filename) //一次性读取整个文件
//TODO : WriteFile
//WriteFile1(filename)
//WriteFile2(filename)
//WriteFile3(filename)
}
~~~
> ### 例子2
~~~
package demo13
import (
"flag"
"fmt"
)
var name string
var age int
func init() {
//flag包获取命令行参数
flag.StringVar(&name, "n", "Go", "A Name")
flag.IntVar(&age, "a", 18, "Age Number")
}
func Demo13() {
/*
类型*File
标准输入 Stdin = NewFile(uintptr(syscall.Stdin), "/dev/stdin")
标准输出 Stdout = NemwFile(uintptr(syscall.Stdout), "/dev/stdout")
标准错误 Stderr = NewFile(uintptr(syscall.Stderr), "/dev/stderr")
*/
/* -----
number := 1
fmt.Printf("1--fmt.Printf:%d\n\r", number)
data1 := fmt.Sprintf("2--fmt.Sprintf:%d", number)
fmt.Println(data1)
//var data2 interface{} interface类型在初始化，是没有分配内存空间给data2变量，相当于nil也就是指一个空指针
var data2 string
fmt.Scan(&data2)
fmt.Println("3--Scan:", data2)
fmt.Scanf("%s", &data2)
fmt.Println("4--Scanf:", data2)
*/
//终端其实是一个文件
//以文件方式操作终端
//不同的运行环境中 console 的 stdin 实现特性不同导致的
/*
var b [16]byte
os.Stdin.Read(b[:])
fmt.Println(string(b[:]))
*/
//从字符串里获取数据 fmt.scanf
//从文件里获取数据 fmt.Fscanf
/*
var a int
var b string
fmt.Fscanf(os.Stdin, "%d%s", &a, &b)
fmt.Println(a, b)
*/
//文件本身读写差
//bufio 带缓冲区文件读写 (大文件)
/*
inputReader := bufio.NewReader(os.Stdin)
input, err := inputReader.ReadString('\n')
if err == nil{
fmt.Println(input)
}
*/
//获取命令行参数
//GoStudy.exe a b c d
/*
for _, v := range os.Args {
fmt.Println(v)
}
*/
//flag包获取命令行参数
fmt.Println(name)
fmt.Println(age)
//github.com/urfave/cli
}
~~~
> ### 1
~~~
package demo14
import (
"os"
"fmt"
"gitee.com/winnie_gss/GoStudy/demo1"
"io"
"bufio"
"io/ioutil"
"compress/gzip"
)
func Exam1() {
file, err := os.Open("D:/demo13.go")
defer file.Close()
demo1.SimplePanic(err)
var b [32]byte
var content []byte
for {
n, err := file.Read(b[:])
//读到没有内容时,报错
if err == io.EOF {
break
}
demo1.SimplePanic(err)
//content = append(content, b[:]...) //最后可能出现没读够
content = append(content, b[:n]...)
}
fmt.Println(string(content))
}
func Exam2() {
file, err := os.Open("D:/demo13.go")
demo1.SimplePanic(err)
reader := bufio.NewReader(file)
for {
line, err := reader.ReadString('\n')
if err == io.EOF {
break
}
demo1.SimplePanic(err)
fmt.Println(line)
}
}
func Exam3() {
content, err := ioutil.ReadFile("D:/demo13.go")
demo1.SimplePanic(err)
fmt.Println(string(content))
}
func Exam4() {
file, err := os.Open("D:/demo13.zip")
demo1.SimplePanic(err)
defer file.Close()
reader, err := gzip.NewReader(file)
demo1.SimplePanic(err)
fmt.Println(reader)
//var b [32]byte
//var content []byte
//
//for {
// n, err := reader.Read(b[:])
// if err == io.EOF {
// break
// }
// demo1.SimplePanic(err)
// content = append(content, b[:n]...)
//}
//fmt.Println(string(content))
}
func Exam5() {
//第二个参数: 文件打开模式
/*
syscall.O_RDONLY // 只读模式打开文件
syscall.O_WRONLY // 只写模式打开文件
syscall.O_RDWR // 读写模式打开文件
syscall.O_APPEND // 写操作时将数据附加到文件尾部
syscall.O_CREAT // 如果不存在将创建一个新文件
syscall.O_EXCL // 和O_CREATE配合使用，文件必须不存在
syscall.O_SYNC // 打开文件用于同步I/O
syscall.O_TRUNC // 如果可能，打开时清空文件
*/
//第三个参数: 权限控制
/*
-rw-r--r--
- | rw- | r-- | r--
1 | 2 | 3 | 4
1 文件类型
2 拥有者权限
3 群组用户权限
4 其它用户权限
r 可读 4
w 可写 2
x 可执行 1
- 无权限 0
*/
file, err := os.OpenFile("D:/demo14.go", os.O_TRUNC|os.O_WRONLY, 0666)
demo1.SimplePanic(err)
str := "Hello World"
file.Write([]byte(str))
}
/*
return x -> 返回值=x , ret指令
*/
func Exam6() (y int) {
x := 5
return x
}
func Exam7() {
file1, err := os.Open("D:/123.txt")
demo1.SimplePanic(err)
file2, err := os.OpenFile("D:/321.txt", os.O_CREATE|os.O_WRONLY, 0666)
demo1.SimplePanic(err)
}
func Demo14() {
//文件读写
//Exam1()
//bufio读取一行数据
//Exam2()
//ioutil读取整个文件
//Exam3()
//读取压缩文件 ????
//Exam4()
//文件写入
//Exam5()
//fmt.Println(Exam6())
//TODO : io.copy 文件拷贝
Exam7()
}
~~~
- 第一序 入门教程(一)
- 1.1环境配置
- 1.1 环境配置(补充:Linux下安装)
- 1.1 环境配置(补充:线上部署)
- 1.2 开发工具GoLand
- 1.3 准备工作
- 1.4 第一个应用程序 Hello World
- 1.4 补充 go get github 超时
- 第二序 入门教程(二)
- 2.1 语法结构
- 2.2 常量, 变量
- 2.2.1 命名规则
- 2.2.2 变量
- 2.2.2 变量(补充:类型推断的好处)
- 2.2.2 变量(补充:泛型)
- 2.2.3 常量
- 2.2.4 iota
- 2.2.5 Unicode字符编码
- 2.2.6 GBK 转 UTF8
- 2.3 条件语句
- 2.3.1 判断语句 if
- 2.3.2 选择语句 switch
- 2.3.3 循环语句 for
- 2.3.4 遍历 range
- 2.3.5 跳转语句 goto, break, continue
- 2.3.6 for 和 for range区别
- 2.4 数组, 切片, 集合, 通道
- 2.4.1 make, len, cap, new, nil
- 2.4.1 make, len, cap, new, nil (补充:nil)
- 2.4.2 数组 array
- 2.4.3.1 切片 slice - 1
- 2.4.3.2 切片 slice - 2
- 2.4.3.3 slice list ring
- 2.4.4 集合 map
- 2.4.5 goroutine
- 2.4.6 channel
- 2.5 函数, 结构, 方法, 接口
- 2.5.1 函数 function
- 2.5.2 结构 struct
- 2.5.3 方法 method
- 2.5.4 接口 interface
- 2.5.5 Go是面向对象的语言吗？
- 2.5.6 json序列化和反序列化
- 2.5.7 T和指针T
- 2.6 defer, panic, recover
- 2.6.1 defer
- 2.6.2 painc, recover
- 2.7 指针
- 2.7 指针(补充: 可寻址和不可寻址)
- 2.8 反射
- 第三序 相关阅读
- 3.1 相关阅读1
- 3.2 相关阅读2
- 3.3 相关阅读3
- 第四序 性能分析和调试工具
- 4.1 pprof工具介绍
- 4.2 CPU信息采集
- 4.3 Heap信息采集
- 4.4 Http信息采集
- 4.5 单元测试(功能测试)
- 4.6 基准测试(压力测试/性能测试)
- 4.7 示例测试(example)
- 4.8 gdb调试
- 第五序 网络编程
- 5.1 http请求和响应
- 5.2 socket
- 5.2.1 概念
- 5.2.2 服务端
- 5.2.3 客户端
- 5.3 WebSocket
- 5.3.1 第一版
- 5.3.1.1 服务端
- 5.3.1.2 客户端
- 5.3.1.3 相关阅读
- 5.3.2 服务端
- 5.3.3 客户端
- 5.3.4 nginx配置
- 5.3.5 修改版
- 5.3.5.1 草稿 - 1
- 5.3.5.2 草稿 - 2
- 5.3.5.3 草稿 - 3
- 5.3.5.4 服务端
- 5.3.5.5 客户端
- 5.4 打印客户端头部信息
- 第六序 算法
- 6.1 查找
- 6.1.1 二分查找
- 6.2 排序
- 6.2.1 交换排序 - 冒泡排序
- 6.2.2 插入排序 - 直接插入排序
- 6.2.3 插入排序 - 希尔排序
- 6.2.4 交换排序 - 快速排序
- 6.3 算法求解应用
- 第七序 微服务
- 7.1 相关阅读
- 7.2 gRPC
- 7.2.1 准备工作
- 7.2.2 编译.proto文件
- 7.2.3 gRPC服务端
- 7.2.4 gRPC客户端
- 7.3 micro/micro
- 7.3.1 服务发现
- 7.3.2 安装consul
- 7.3.3 准备工作
- 7.3.4 服务端
- 7.3.5 客户端
- 7.3.6 默认的服务发现
- 7.3.7 文档阅读
- 7.4 protobuf序列化
- 第八序 Web
- 8.1 视图模板
- 8.1.1 main.go
- 8.1.2 login.html
- 8.2 原生留言板
- 8.2.1 原生sql
- 8.2.1.1 main.go
- 8.2.1.2 view
- 8.2.1.2.1 index.html
- 8.2.1.2.2 create.html
- 8.2.2 sqlx
- 8.3 Gin框架
- 第九序 数据库
- 9.0 资料收集
- 9.1 Redis数据库 (gomodule/redigo)
- 9.1.1 介绍
- 9.1.2 消息队列
- 9.2 Redis数据库(go-redis/redis)
- 第十序 日记
- 10.1 SimplePanic
- 10.2 第一版日记库
- 10.2.1 winnielog
- 10.2.2 使用
- 第十一序 中间键
- 11.0 资料收集
- 11.1 NSQ
- 11.2 zookeeper
- 11.3 kafka
- 第十二序 加密
- 12.1 Token
- 12.2 SHA1
- 2.3 RSA + AES
- 第十三序 分布式锁
- 第十四序 标准库练习
- container/list
- 链表
- container/ring
- 环形链表
- context
- flag (获取命令行参数)
- io
- strconv
- sync
- 为什么需要锁?
- 互斥锁
- 读写锁
- 条件变量
- 计数器
- 并发安全字典
- 自制并发安全字典
- 官方并发安全字典
- 连接池
- sync/atomic
- 原子操作
- 第十五序 其它内容
- 文件读写
- 工作池
- 第十六序 相关阅读