add multiple-epoller client

Author: smallnest

4_epoll_client/build.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+go build --tags "static netgo" -o client  .

4_epoll_client/epoll_linux.go

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+go build --tags "static netgo" -o mclient  .

4_epoll_client/epoll_other.go

@@ -72,10 +72,23 @@ func mkClient(addr string, connections int) {
 
 	go start(epoller)
 
+	tts := time.Second
+	if *c > 100 {
+		tts = time.Millisecond * 5
+	}
+
 	for i := 0; i < len(conns); i++ {
+		time.Sleep(tts)
 		conn := conns[i]
-		conn.Write([]byte("hello world\r\n"))
+		err = binary.Write(conn, binary.BigEndian, time.Now().UnixNano())
+		if err := epoller.Remove(conn); err != nil {
+			log.Printf("failed to write timestamp %v", err)
+			if err := epoller.Remove(conn); err != nil {
+				log.Printf("failed to remove %v", err)
+			}
+		}
 	}
+
 }
 
 func start(epoller *epoll) {
@@ -99,7 +112,7 @@ func start(epoller *epoll) {
 				opsRate.Update(time.Duration(time.Now().UnixNano() - nano))
 			}
 
-			err = binary.Write(conn, binary.BigEndian, []byte("hello world\r\n"))
+			err = binary.Write(conn, binary.BigEndian, time.Now().UnixNano())
 			if err != nil {
 				if err := epoller.Remove(conn); err != nil {
 					log.Printf("failed to remove %v", err)

5_multiple_client/build.sh

@@ -0,0 +1,16 @@
+#!/bin/bash
+## 这个脚本使用Docker在不同的网络命名空间产生多个client实例.
+## 这样才能避免source port的限制，在一台机器上才能创建百万的连接.
+##
+## 用法: ./connect <connections> <number of clients> <server ip>
+## Server IP 通常是 Docker gateway IP address, 缺省是 172.17.0.1
+
+CONNECTIONS=$1
+REPLICAS=$2
+IP=$3
+CONCURRENCY=$4
+
+for (( c=0; c<${REPLICAS}; c++ ))
+do
+    docker run -v $(pwd)/mclient:/client --name 1mclient_$c -d frolvlad/alpine-glibc /client -conn=${CONNECTIONS} -ip=${IP} -c=${CONCURRENCY}
+done