本文開發(fā)語言基于Swift 代碼參考EchoServer
目錄
環(huán)境
MacOS安裝Xcode即可 所以以下環(huán)境搭建基于Ubuntu1604
sudo apt install -y clang libicu-dev git
git clone https://github.com/kylef/swiftenv.git ~/.swiftenv
echo 'export SWIFTENV_ROOT="$HOME/.swiftenv"' >> ~/.zshrc
echo 'export PATH="$SWIFTENV_ROOT/bin:$PATH"' >> ~/.zshrc
echo 'eval "$(swiftenv init -)"' >> ~/.zshrc
source ~/.zshrc
swiftenv install 4.0.3
swift --version
關(guān)于swiftenv 更多參考swiftenv
開始
mkdir EchoServer
# cd EchoServer
swift package init --type executable
swift build
.build/debug/EchoServer
Hello, world!
NIO
vim Package.swift
// swift-tools-version:4.0
// The swift-tools-version declares the minimum version of Swift required to build this package.
import PackageDescription
let package = Package(
name: "EchoServer",
dependencies: [
// Dependencies declare other packages that this package depends on.
// .package(url: /* package url */, from: "1.0.0"),
.package(url: "https://github.com/apple/swift-nio.git", from: "1.1.0"),
],
targets: [
// Targets are the basic building blocks of a package. A target can define a module or a test suite.
// Targets can depend on other targets in this package, and on products in packages which this package depends on.
.target(
name: "EchoServer",
dependencies: ["NIO"]),
]
)
swift package resolve
vim Sources/EchoServer/main.swift
import NIO
// EchoHandler
private final class EchoHandler: ChannelInboundHandler {
public typealias InboundIn = ByteBuffer
public typealias OutboundOut = ByteBuffer
private var count: Int = 0
public func channelRegistered(ctx: ChannelHandlerContext) {
print("channel registered:", ctx.remoteAddress ?? "unknown")
}
public func channelUnregistered(ctx: ChannelHandlerContext) {
print("channel unregistered")
}
public func channelRead(ctx: ChannelHandlerContext, data: NIOAny) {
let buffer = self.unwrapInboundIn(data)
print("read:", buffer.getString(at: 0, length: buffer.readableBytes)!)
ctx.write(data, promise: nil)
}
public func channelReadComplete(ctx: ChannelHandlerContext) {
print("read complete")
ctx.flush()
}
public func errorCaught(ctx: ChannelHandlerContext, error: Error) {
print("error: ", error)
ctx.close(promise: nil)
}
}
// Bootstrap
let group = MultiThreadedEventLoopGroup(numThreads: System.coreCount)
let bootstrap = ServerBootstrap(group: group)
.serverChannelOption(ChannelOptions.backlog, value: 256)
.serverChannelOption(ChannelOptions.socket(SocketOptionLevel(SOL_SOCKET), SO_REUSEADDR), value: 1)
.childChannelInitializer { channel in
channel.pipeline.add(handler: BackPressureHandler()).then { v in
channel.pipeline.add(handler: EchoHandler())
}
}
.childChannelOption(ChannelOptions.socket(IPPROTO_TCP, TCP_NODELAY), value: 1)
.childChannelOption(ChannelOptions.socket(SocketOptionLevel(SOL_SOCKET), SO_REUSEADDR), value: 1)
.childChannelOption(ChannelOptions.maxMessagesPerRead, value: 16)
.childChannelOption(ChannelOptions.recvAllocator, value: AdaptiveRecvByteBufferAllocator())
defer {
try! group.syncShutdownGracefully()
}
let channel = try bootstrap.bind(host: "::1", port: 9999).wait()
print("Server started and listening on \(channel.localAddress!)")
try channel.closeFuture.wait()
print("Server terminated")
測(cè)試
- Server
swift build && .build/debug/EchoServer
Compile Swift Module 'EchoServer' (1 sources)
Server started and listening on [IPv6]::1:9999
- Client
telnet localhost 9999
MacOS安裝telnet方法: brew install telnet
Trying ::1...
Connected to localhost.
Escape character is '^]'.
- Close
^]
telnet> close
概念
mkdir Node
# cd Node
echo "file content" >> ./file
Blocking I/O
vim bio.js
console.log('start')
const data = require('fs').readFileSync('./file');
console.log('read:', data.toString());
console.log('end');
node bio.js
start
read: file content
end
Non-Blocking I/O
vim nio.js
console.log('start')
require('fs').readFile('./file', (err, data) => {
if (err) throw err;
console.log(data.toString());
});
console.log('end');
node nio.js
start
end
read: file content
