Unable to attach a http server with aedes server , like mosca's attachHttpServer . Any workaround ? about aedes HOT 5 CLOSED

moscajs commented on August 20, 2024

Unable to attach a http server with aedes server , like mosca's attachHttpServer . Any workaround ?

from aedes.

Comments (5)

alliv8 commented on August 20, 2024 1

You have to bind aedes to wss, not a new tcp server.

var http = require('http')
var websocket = require('websocket-stream')
var RedisPersistence = require('aedes-persistence-redis')()
var aedes = require('aedes')({
    concurrency: 1000,
    persistence : RedisPersistence
})

var httpServ = http.createServer()
var port = 1884

var wss = websocket.createServer({server: httpServ, port: port}, aedes.handle)

This should work

from aedes.

mcollina commented on August 20, 2024

This is not in the scope of this project, and it will be integrated with Mosca soon. You can achieve the same thing by using http://npm.im/websocket-stream.

from aedes.

debjeetsarkar commented on August 20, 2024

I am sending my client side packet using mows.js and I am trying to pass the incoming stream to aedes using websocket-stream . Here is my code snippet

var http = require('http')
var websocket = require('websocket-stream')
var RedisPersistence = require('aedes-persistence-redis')()
var aedes = require('aedes')({
    concurrency: 1000,
    persistence : RedisPersistence
})

var httpServ = http.createServer()

var wss = websocket.createServer({server: httpServ},handle)

function handle(stream){
    stream.pipe(server)
}

var server = require('net').createServer(aedes.handle)
var port = 1884 


httpServ.listen(port, function (req,res) {
  console.log('server listening on port', port)
})