最近 业务都是使用的socket 进行连接 推送也是使用 mqtt 对于 开发来说 了解TCP知识 必不可少，我也稍稍带点 soket的一点知识，希望能对朋友们有点帮助。
不BB 直接说业务场景。客户端需要连接至网关，网关持有该socket 自己再去创建个socket至交易所，交易所有信息通知都会走该socket，同时我们的部分业务需要通知客户端的也会走网关socket，同时所有的数据传输都是使用pb,
- 准备工作
typescript vscode 环境配置
node 网关
telnet 客户端
protobuffer 不介绍了 - typescript
微软开源的强类型编程语言 js 的超集 完美兼容es
我们开发环境使用 ts + vscode
- 安装ts
npm init -g -s tsc
在工程目录下tsc init不成功的话 直接创建一个 tsconfig.json文件即可
{
"compilerOptions": {
"target": "es6",
"sourceMap": true,
"module": "commonjs",
"outDir": "./dist",
"noImplicitAny": true,
},
"include": [
"src/**/*"
]
}
创建 src 文件夹 以及 dist 文件夹 ok 继续 command+shift+B 选择监视后面我们有改动的话就可以自动生成js 代码 但是会有.map文件存在 到时候git 上传时 忽略即可.此时 我们的代码可以使用ts 进行书写 并且调试 爽歪歪
- node 网关
我们不管 ssl 还是 tsl 就用 最简单的 net 创建一个 socket网关。
import * as TCP from "net"
const tcp = TCP.createServer((socket:TCP.Socket)=>{
const buffer:Buffer = new Buffer("hello",'utf-8')
// socket.write(buffer)
console.log('CONNECTED: ' +
socket.remoteAddress + ':' + socket.remotePort);
socket.write(buffer);
socket.on('data', function(data) {
console.log('DATA ' + socket.remoteAddress + ': ' + data);
// 回发该数据，客户端将收到来自服务端的数据
socket.write('You said "' + data + '"');
});
})
tcp.listen(3999,()=>{
console.log('1234')
})
这个就是一个tcp 服务 运行它
- telnet
mac 下安装telnet
brew install telnet
我们 使用telnet 连接至 网关
telnet localhost 3999
输出 hello 表示我们连接成功 同时可以打断点调试。
4.有个业务需求是 客户端http请求某个接口 后 可以通知到某个socket 连接。
我们用数组添加 每个socket 如果连接上就存着 如果断开连接 该数组清掉这个socket
上全部代码
import * as TCP from "net"
import * as http from "http"
import { Socket } from "net";
const sockets : Array<TCP.Socket> = new Array()
const tcp = TCP.createServer((socket:TCP.Socket)=>{
sockets.push(socket)
const buffer:Buffer = new Buffer("hello",'utf-8')
// socket.write(buffer)
console.log('CONNECTED: ' +
socket.remoteAddress + ':' + socket.remotePort);
socket.write(buffer);
socket.on('data', function(data) {
console.log('DATA ' + socket.remoteAddress + ': ' + data);
// 回发该数据，客户端将收到来自服务端的数据
socket.write('You said "' + data + '"');
});
})
tcp.listen(3999,()=>{
console.log('1234')
})
const app = http.createServer((req,res)=>{
if(req.url == "/socket"){
const s = sockets[0]
s.write(" 我是你爹啊")
}
})
app.listen(3000)
t1(1)
至此 一个socket 网关完成 传输部分可以使用pb替代。再添加tsl 链接加密
