当前位置：网站首页>Nodejs + websocket cycle small case

Nodejs + websocket cycle small case

2022-04-23 13:06:00 【It's never too late to be alone】

Start a project , Let's install one for the project first nodeJs Module , It's called nodejs-websocket ,

npm install nodejs-websocket

Server side 

var ws = require("nodejs-websocket")
 
var index = 0;
let IndexNum;
 
var server = ws.createServer(function(conn) {
    
    console.log("New connection")
    //conn.on("***",function(){})  The binding event (***) And event handlers 
    conn.on("text", function(str) {
    // event ：“ text（str）” Send... When text is received .str Is a string 
        console.log(str);
       if(str == 1 ){
    
           IndexNum = setInterval(()=>{
    
            let mes = {
    };  
            mes.index = index++;
            mes.number = parseInt (Math.random()*100);
            //JSON.stringify(mes) Serialization object , Convert the type of object to string type 
            conn.sendText(JSON.stringify(mes));// Send the given string to the front end 
           },1000);
       }else{
    
           conn.sendText('erro');
       }
    })
    conn.on("close", function(code) {
    // Start closing the handshake （ Send close frame ）
        console.log(" close ",code);
        clearInterval(IndexNum);
    })
    conn.on("error", function(err) {
    // Issue when an error occurs . If the handshake doesn't work , Will also respond .
        console.log(err);
    })
}).listen(3000);// Server listening port 3000
 
console.log("websocket server running on port: 3000");

client 

<body>
    <button onclick="begin()"> Start </button>
    <button onclick="stop()"> stop it </button>
    <div class="box"></div>
    <script type="text/javascript"> var websocket = new WebSocket("ws://localhost:3000/"); var box = document.getElementsByClassName('box')[0]; websocket.onopen = function() {
      console.log(" Successful connection "); } websocket.onclose = function() {
      console.log("websocket close"); } function begin(){
      websocket.send(1); } function stop(){
      websocket.close(); } //  Only receive string parameters , So on the server side, it is said that the object can be used JSON Convert to a string first , Then turn it into an object here  websocket.onmessage = function(e) {
      let data = JSON.parse(e.data); let text = `<li> The first ${
       data.index} Time , The number is ${
       data.number};</li>` box.innerHTML += text; } </script>
</body>

client
Server side

版权声明
本文为[It's never too late to be alone]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/04/202204231303465578.html

边栏推荐

猜你喜欢

随机推荐