【发布时间】:2016-10-25 12:28:10
【问题描述】:
const express = require('express');
const helmet = require('helmet');
const bodyParser = require('body-parser');
const morgan = require('morgan');
const path = require('path');
const server = require('./modules/server');
const dashboard = require('./modules/dashboard');
const config = require('./config');
const routes = require('./routes');
const app = express();
app.use(helmet()); // secure http communication middleware
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(morgan('tiny')); // http request logger
app.use('/', routes);
app.use('/public', express.static(path.join(__dirname, '/public')));
// Serve the Parse API on the /parse URL prefix
const mountPath = process.env.PARSE_MOUNT || '/parse';
app.use(mountPath, server);
app.use('/dashboard', dashboard);
/**
* Mosca Server Settings below
*/
var mosca = require('mosca');
var http = require('http');
var httpServer = http.createServer(app);
var moscaSettingss = {
type: 'mongo',
url: 'mongodb://***:31157/mqtt',
pubsubCollection: 'pub_sub',
mongo: {}
};
httpServer= new mosca.Server({
backend: moscaSettingss,
persistence: {
factory: mosca.persistence.Mongo,
url: 'mongodb://***:31157/mqtt'
}
}, function() {
httpServer.attachHttpServer(app);
});
httpServer.on('ready', function() {
console.log('Mosca is running');
});
httpServer.on('clientConnected', function(client) {
console.log('client connected', client.id);
});
httpServer.on('published', function(packet, client) {
console.log('Published : ', packet.payload);
});
httpServer.on('subscribed', function(topic, client) {
console.log('subscribed : ', topic);
});
httpServer.on('unsubscribed', function(topic, client) {
console.log('unsubscribed : ', topic);
});
httpServer.on('clientDisconnecting', function(client) {
console.log('clientDisconnecting : ', client.id);
});
httpServer.on('clientDisconnected', function(client) {
console.log('clientDisconnected : ', client.id);
});
/**
* End of Mosca Server Settings
*/
app.listen(config.server.port, () => {
console.log(`Magic happens on port ${config.server.port}`);
});
module.exports = app;
我制作了一个快递应用,其中包含 mosca mqtt 代理。有些我无法连接到那个 mqtt。尝试了所有可能的网址。
在express应用中,我做了一个mqtt客户端,成功连接到broker。但是在 Heroku 之外,我的设备无法连接。
等待回复。
【问题讨论】:
-
@Molda 我试过了,但没用。
-
没有看到任何代码真的很难判断问题出在哪里。您能否补充一下您如何设置 mosca 和 express 的问题?
-
@Molda 我添加了源文件,请看一下。如果在此应用程序中创建一个 mqtt 客户端,则此代码有效。但是在这个heroku服务器之外,我无法连接到代理。
-
另一件事你如何从客户端连接?
标签: node.js express heroku mosca