谁是虽好的语言 ？- 语言选型闲聊（上）

# py-amqp-5.0.6/amqp/method_framing.py
def frame_writer(connection, transport,
                 pack=pack, pack_into=pack_into, range=range, len=len,
                 bytes=bytes, str_to_bytes=str_to_bytes, text_t=str):
    """Create closure that writes frames."""
    write = transport.write
    ...
    write(pack('>BHI%dsB' % framelen,
                       type_, channel, framelen, frame, 0xce))
    ...
复制代码

| 框架            | QPS (plaintext/json) |
| --------------- | -------------------- |
| nginx           | 85267                |
| go              | 89354/87626          |
| node            | 45212/40965          |
| node-thread     | 31487/32903          |
| node-cluster(2) | 77450/71943          |
| pypy3+twisted   | 14349/15921          |
| python3+aiohttp | 4959/4625            |
| c#              | 59347/58829            
复制代码

//add this code snippet to main.js
const { Worker } = require('worker_threads')
const runService = (WorkerData) => {
    console.log(WorkerData)
    return new Promise((resolve, reject) => {
        // import workerExample.js script..
        // 注意workerData是一个字典
        const worker = new Worker('./workerExample.js', { workerData:WorkerData });
        worker.on('message', resolve);
        worker.on('error', reject);
        worker.on('exit', (code) => {
            if (code !== 0)
                reject(new Error(`stopped with  ${code} exit code`));
        })
    })
}
const run = async () => {
    const result = await runService('hello John Doe')
    console.log(result);
}
run().catch(err => console.error(err))
复制代码

// add this to workerExample.js file.
const { workerData, parentPort } = require('worker_threads')
console.log("receive:", workerData)
parentPort.postMessage({ welcome: workerData })
复制代码

# worker.js
const path = require("path");
require("ts-node").register();
require(path.resolve(__dirname, "./worker.ts"));
# worker.ts
import worker from "worker_threads";
const wd = worker.workerData;
process.on('message', func(this));
复制代码

# package.json
{
    "devDependencies": {
        "@lerna/batch-packages": "^3.16.0",
        "@lerna/filter-packages": "^4.0.0",
        "@lerna/project": "^4.0.0",
        "@rollup/plugin-commonjs": "^17.1.0",
        "@rollup/plugin-json": "^4.1.0",
        "@rollup/plugin-node-resolve": "^11.2.0",
        "@rollup/plugin-typescript": "^8.2.1",
        "@types/debug": "^0.0.31",
        "@types/express": "^4.16.1",
        "@types/fossil-delta": "^1.0.0",
        "@types/jest": "^26.0.24",
        "@types/koa": "^2.0.49",
        "@types/mocha": "^5.2.7",
        "@types/node": "^16.3.2",
        "@types/sinon": "^10.0.2",
        "all-contributors-cli": "^5.4.0",
        "assert": "^2.0.0",
        "benchmark": "^2.1.1",
        "c8": "^7.7.2",
        "colyseus.js": "^0.14.13",
        "cors": "^2.8.5",
        "express": "^4.16.2",
        "httpie": "^2.0.0-next.13",
        "jest": "^27.0.6",
        "koa": "^2.8.1",
        "lerna": "^4.0.0",
        "minimist": "^1.2.5",
        "mocha": "^5.1.1",
        "rimraf": "^2.7.1",
        "rollup": "^2.47.0",
        "rollup-plugin-node-externals": "^2.2.0",
        "sinon": "^11.1.1",
        "ts-jest": "^27.0.3",
        "ts-node": "^7.0.1",
        "ts-node-dev": "^1.1.6",
        "tslint": "^5.11.0",
        "typescript": "^4.3.5"
  },
}
复制代码

using System;
using System.IO;
using System.Text;
using System.Net;
using System.Threading.Tasks;
namespace HttpListenerExample
{
    class HttpServer
    {
        public static HttpListener listener;
        public static string url = "http://localhost:8000/";
        public static async Task HandleIncomingConnections()
        {
            // While a user hasn't visited the `shutdown` url, keep on handling requests
            while (true)
            {
                // Will wait here until we hear from a connection
                HttpListenerContext ctx = await listener.GetContextAsync();
                // Peel out the requests and response objects
                HttpListenerRequest req = ctx.Request;
                HttpListenerResponse resp = ctx.Response;
                // Print out some info about the request
                Console.WriteLine(req.Url.ToString());
                Console.WriteLine(req.HttpMethod);
                Console.WriteLine(req.UserHostName);
                Console.WriteLine(req.UserAgent);
                byte[] data = Encoding.UTF8.GetBytes("Hello, c#");
                resp.ContentType = "text/html";
                resp.ContentEncoding = Encoding.UTF8;
                resp.ContentLength64 = data.LongLength;
                // Write out to the response stream (asynchronously), then close it
                await resp.OutputStream.WriteAsync(data, 0, data.Length);
                resp.Close();
            }
        }
        public static void Start()
        {
            // Create a Http server and start listening for incoming connections
            listener = new HttpListener();
            listener.Prefixes.Add(url);
            listener.Start();
            Console.WriteLine("Listening for connections on {0}", url);
            // Handle requests
            Task listenTask = HandleIncomingConnections();
            listenTask.GetAwaiter().GetResult();
            // Close the listener
            listener.Close();
        }
    }
}
复制代码