lostecho/build-web-application-with-golang
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #935 from invzhi/master

Browse Source 
Update some code and tweak format details
This commit is contained in:
astaxie
2017-12-18 19:30:14 +08:00
committed by GitHub
parent 018021a8cc ba974656c6
commit f3ed9164cc
3 changed files with 25 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
zh/06.2.md
View File

@@ -35,18 +35,18 @@ session的基本原理是由服务器为每个会话维护一份信息数据，
```Go ```Go
type Manager struct { type Manager struct {
cookieName string //private cookiename cookieName string // private cookiename
lock sync.Mutex // protects session lock sync.Mutex // protects session
provider Provider provider Provider
maxlifetime int64 maxLifeTime int64
} }
func NewManager(provideName, cookieName string, maxlifetime int64) (*Manager, error) { func NewManager(provideName, cookieName string, maxLifeTime int64) (*Manager, error) {
provider, ok := provides[provideName] provider, ok := provides[provideName]
if !ok { if !ok {
return nil, fmt.Errorf("session: unknown provide %q (forgotten import?)", provideName) return nil, fmt.Errorf("session: unknown provide %q (forgotten import?)", provideName)
} }
return &Manager{provider: provider, cookieName: cookieName, maxlifetime: maxlifetime}, nil return &Manager{provider: provider, cookieName: cookieName, maxLifeTime: maxLifeTime}, nil
} }
``` ```
@@ -56,7 +56,7 @@ Go实现整个的流程应该也是这样的，在main包中创建一个全局
var globalSessions *session.Manager var globalSessions *session.Manager
//然后在init函数中初始化 //然后在init函数中初始化
func init() { func init() {
globalSessions, _ = NewManager("memory","gosessionid",3600) globalSessions, _ = NewManager("memory", "gosessionid", 3600)
} }
``` ```
我们知道session是保存在服务器端的数据，它可以以任何的方式存储，比如存储在内存、数据库或者文件中。因此我们抽象出一个Provider接口，用以表征session管理器底层存储结构。 我们知道session是保存在服务器端的数据，它可以以任何的方式存储，比如存储在内存、数据库或者文件中。因此我们抽象出一个Provider接口，用以表征session管理器底层存储结构。
@@ -78,10 +78,10 @@ type Provider interface {
```Go ```Go
type Session interface { type Session interface {
Set(key, value interface{}) error //set session value Set(key, value interface{}) error // set session value
Get(key interface{}) interface{} //get session value Get(key interface{}) interface{} // get session value
Delete(key interface{}) error //delete session value Delete(key interface{}) error // delete session value
SessionID() string //back current sessionID SessionID() string // back current sessionID
} }
``` ```
>以上设计思路来源于database/sql/driver，先定义好接口，然后具体的存储session的结构实现相应的接口并注册后，相应功能这样就可以使用了，以下是用来随需注册存储session的结构的Register函数的实现。 >以上设计思路来源于database/sql/driver，先定义好接口，然后具体的存储session的结构实现相应的接口并注册后，相应功能这样就可以使用了，以下是用来随需注册存储session的结构的Register函数的实现。
@@ -128,7 +128,7 @@ func (manager *Manager) SessionStart(w http.ResponseWriter, r *http.Request) (se
if err != nil || cookie.Value == "" { if err != nil || cookie.Value == "" {
sid := manager.sessionId() sid := manager.sessionId()
session, _ = manager.provider.SessionInit(sid) session, _ = manager.provider.SessionInit(sid)
cookie := http.Cookie{Name: manager.cookieName, Value: url.QueryEscape(sid), Path: "/", HttpOnly: true, MaxAge: int(manager.maxlifetime)} cookie := http.Cookie{Name: manager.cookieName, Value: url.QueryEscape(sid), Path: "/", HttpOnly: true, MaxAge: int(manager.maxLifeTime)}
http.SetCookie(w, &cookie) http.SetCookie(w, &cookie)
} else { } else {
sid, _ := url.QueryUnescape(cookie.Value) sid, _ := url.QueryUnescape(cookie.Value)
@@ -204,18 +204,21 @@ func (manager *Manager) SessionDestroy(w http.ResponseWriter, r *http.Request){
``` ```
### session销毁 ### session销毁
我们来看一下Session管理器如何来管理销毁,只要我们在Main启动的时候启动： 我们来看一下Session管理器如何来管理销毁，只要我们在Main启动的时候启动：
```Go ```Go
func init() { func init() {
go globalSessions.GC() go globalSessions.GC()
} }
```
```Go
func (manager *Manager) GC() { func (manager *Manager) GC() {
manager.lock.Lock() manager.lock.Lock()
defer manager.lock.Unlock() defer manager.lock.Unlock()
manager.provider.SessionGC(manager.maxlifetime) manager.provider.SessionGC(manager.maxLifeTime)
time.AfterFunc(time.Duration(manager.maxlifetime), func() { manager.GC() }) time.AfterFunc(time.Duration(manager.maxLifeTime), func() { manager.GC() })
} }
``` ```
我们可以看到GC充分利用了time包中的定时器功能，当超时`maxLifeTime`之后调用GC函数，这样就可以保证`maxLifeTime`时间内的session都是可用的，类似的方案也可以用于统计在线用户数之类的。 我们可以看到GC充分利用了time包中的定时器功能，当超时`maxLifeTime`之后调用GC函数，这样就可以保证`maxLifeTime`时间内的session都是可用的，类似的方案也可以用于统计在线用户数之类的。

1
zh/06.3.md
View File

@@ -32,7 +32,6 @@ func (st *SessionStore) Get(key interface{}) interface{} {
} else { } else {
return nil return nil
} }
return nil
} }
func (st *SessionStore) Delete(key interface{}) error { func (st *SessionStore) Delete(key interface{}) error {

16
zh/08.1.md
View File

@@ -5,6 +5,7 @@
Socket起源于Unix，而Unix基本哲学之一就是“一切皆文件”，都可以用“打开open –> 读写write/read –> 关闭close”模式来操作。Socket就是该模式的一个实现，网络的Socket数据传输是一种特殊的I/O，Socket也是一种文件描述符。Socket也具有一个类似于打开文件的函数调用：Socket()，该函数返回一个整型的Socket描述符，随后的连接建立、数据传输等操作都是通过该Socket实现的。 Socket起源于Unix，而Unix基本哲学之一就是“一切皆文件”，都可以用“打开open –> 读写write/read –> 关闭close”模式来操作。Socket就是该模式的一个实现，网络的Socket数据传输是一种特殊的I/O，Socket也是一种文件描述符。Socket也具有一个类似于打开文件的函数调用：Socket()，该函数返回一个整型的Socket描述符，随后的连接建立、数据传输等操作都是通过该Socket实现的。
常用的Socket类型有两种：流式Socket（SOCK_STREAM）和数据报式Socket（SOCK_DGRAM）。流式是一种面向连接的Socket，针对于面向连接的TCP服务应用；数据报式Socket是一种无连接的Socket，对应于无连接的UDP服务应用。 常用的Socket类型有两种：流式Socket（SOCK_STREAM）和数据报式Socket（SOCK_DGRAM）。流式是一种面向连接的Socket，针对于面向连接的TCP服务应用；数据报式Socket是一种无连接的Socket，对应于无连接的UDP服务应用。
## Socket如何通信 ## Socket如何通信
网络中的进程之间如何通过Socket通信呢？首要解决的问题是如何唯一标识一个进程，否则通信无从谈起！在本地可以通过进程PID来唯一标识一个进程，但是在网络中这是行不通的。其实TCP/IP协议族已经帮我们解决了这个问题，网络层的“ip地址”可以唯一标识网络中的主机，而传输层的“协议+端口”可以唯一标识主机中的应用程序（进程）。这样利用三元组（ip地址，协议，端口）就可以标识网络的进程了，网络中需要互相通信的进程，就可以利用这个标志在他们之间进行交互。请看下面这个TCP/IP协议结构图 网络中的进程之间如何通过Socket通信呢？首要解决的问题是如何唯一标识一个进程，否则通信无从谈起！在本地可以通过进程PID来唯一标识一个进程，但是在网络中这是行不通的。其实TCP/IP协议族已经帮我们解决了这个问题，网络层的“ip地址”可以唯一标识网络中的主机，而传输层的“协议+端口”可以唯一标识主机中的应用程序（进程）。这样利用三元组（ip地址，协议，端口）就可以标识网络的进程了，网络中需要互相通信的进程，就可以利用这个标志在他们之间进行交互。请看下面这个TCP/IP协议结构图
@@ -71,8 +72,8 @@ func main() {
```Go ```Go
func (c *TCPConn) Write(b []byte) (n int, err os.Error) func (c *TCPConn) Write(b []byte) (int, error)
func (c *TCPConn) Read(b []byte) (n int, err os.Error) func (c *TCPConn) Read(b []byte) (int, error)
``` ```
`TCPConn`可以用在客户端和服务器端来读写数据。 `TCPConn`可以用在客户端和服务器端来读写数据。
@@ -84,6 +85,7 @@ func (c *TCPConn) Read(b []byte) (n int, err os.Error)
type TCPAddr struct { type TCPAddr struct {
IP IP IP IP
Port int Port int
Zone string // IPv6 scoped addressing zone
} }
``` ```
在Go语言中通过`ResolveTCPAddr`获取一个`TCPAddr` 在Go语言中通过`ResolveTCPAddr`获取一个`TCPAddr`
@@ -93,8 +95,8 @@ type TCPAddr struct {
func ResolveTCPAddr(net, addr string) (*TCPAddr, os.Error) func ResolveTCPAddr(net, addr string) (*TCPAddr, os.Error)
``` ```
- net参数是"tcp4"、"tcp6"、"tcp"中的任意一个，分别表示TCP(IPv4-only),TCP(IPv6-only)或者TCP(IPv4,IPv6的任意一个). - net参数是"tcp4"、"tcp6"、"tcp"中的任意一个，分别表示TCP(IPv4-only), TCP(IPv6-only)或者TCP(IPv4, IPv6的任意一个)。
- addr表示域名或者IP地址，例如"www.google.com:80" 或者"127.0.0.1:22". - addr表示域名或者IP地址，例如"www.google.com:80" 或者"127.0.0.1:22"。
### TCP client ### TCP client
@@ -102,7 +104,7 @@ Go语言中通过net包中的`DialTCP`函数来建立一个TCP连接，并返回
```Go ```Go
func DialTCP(net string, laddr, raddr *TCPAddr) (c *TCPConn, err os.Error) func DialTCP(network string, laddr, raddr *TCPAddr) (*TCPConn, error)
``` ```
- net参数是"tcp4"、"tcp6"、"tcp"中的任意一个，分别表示TCP(IPv4-only)、TCP(IPv6-only)或者TCP(IPv4,IPv6的任意一个) - net参数是"tcp4"、"tcp6"、"tcp"中的任意一个，分别表示TCP(IPv4-only)、TCP(IPv6-only)或者TCP(IPv4,IPv6的任意一个)
- laddr表示本机地址，一般设置为nil - laddr表示本机地址，一般设置为nil
@@ -166,8 +168,8 @@ func checkError(err error) {
上面我们编写了一个TCP的客户端程序，也可以通过net包来创建一个服务器端程序，在服务器端我们需要绑定服务到指定的非激活端口，并监听此端口，当有客户端请求到达的时候可以接收到来自客户端连接的请求。net包中有相应功能的函数，函数定义如下： 上面我们编写了一个TCP的客户端程序，也可以通过net包来创建一个服务器端程序，在服务器端我们需要绑定服务到指定的非激活端口，并监听此端口，当有客户端请求到达的时候可以接收到来自客户端连接的请求。net包中有相应功能的函数，函数定义如下：
```Go ```Go
func ListenTCP(net string, laddr *TCPAddr) (l *TCPListener, err os.Error) func ListenTCP(network string, laddr *TCPAddr) (*TCPListener, error)
func (l *TCPListener) Accept() (c Conn, err os.Error) func (l *TCPListener) Accept() (Conn, error)
``` ```
参数说明同DialTCP的参数一样。下面我们实现一个简单的时间同步服务，监听7777端口 参数说明同DialTCP的参数一样。下面我们实现一个简单的时间同步服务，监听7777端口
```Go ```Go