Tag: socket.io

如何使像Facebook一样的多节点js聊天?

好吧,我已经读了一些教程,我有节点js与快递和套接字io聊天,它运作良好! 所以,它的工作方式是:打开端口3000中的URL的用户连接,现在不能发送消息,如果另一个用户连接在同一个URL和端口现在可以看到他也可以发送消息的新消息。 我想在同一个应用程序中有这样的多个场景,使像Facebook聊天!!,谢谢! 这是我有的代码:服务器端: var app = require('express')(); var http = require('http').Server(app); var io = require('socket.io')(http); app.get('/', function(req, res){ res.sendFile(__dirname+'/index.html'); }); io.on('connection', function(socket){ console.log('a user connected'); socket.on('chat message', function(msg){ io.emit('chat message', msg); }); socket.on('disconnect', function(){ console.log('user disconnected'); }); }); http.listen(3000, function(){ console.log('listening on *:3000'); }); 在客户端javascript: var socket = io(); $('form').submit(function(){ socket.emit('chat message', {message: $('#m').val(), […]

Node-amqp和socket.io奇怪的行为

我实际上试图使用node-amqp( https://github.com/postwait/node-amqp )实现pub / sub模式。 我有一些问题来实现它。 我需要的 : 从用户发布消息 将其广播给其他用户 将邮件发送给离线用户,下次连接时会使用该邮件 我其实是: (function () { var amqp = require('amqp'); var connection = amqp.createConnection({ host: 'http://127.0.0.1:5672/' }); var app = require('express')(); var server = require('http').Server(app); var io = require('socket.io')(server); app.get('/', function (req, res) { res.sendfile(__dirname + '/index.html'); }); server.listen(8888); // Wait for connection to become established. […]

需要使用Socket ioparsing生活的json文件

头一回! 我是非常新的node.js和socket.io世界我有一个json文件,其中包含以下数据,例如: – { "football": { "id": 1, "home": "Liverpool", "away": "Chelsea", "score": "1-0", "last scorer":"Gerrard" } } 此文件在几秒钟内实时更新。 我真正想要实现的是parsing这个JSON,并在客户端更新相同的HTML,除此之外,我想听取任何更改的JSON文件,并再次更新到HTML客户端。 我怎么能做到这一点,对不起,如果这个问题似乎足够愚蠢,但任何build议可以帮助。

只使用socket-io和web客户端(socket io js)进行安全交换

我在debian 8虚拟机上用openssl创build了一个SSL证书。 所以我有一个包含我的密钥和证书的PEM文件。 我想知道是否有可能不使用https,express等使用SSL证书,只需使用带有套接字IO(服务器端)和套接字IO客户端(客户端)的体系结构即可。 服务器端 : var fs = require("fs") , options = { key : fs.readFileSync('./test/apache.pem'), cert : fs.readFileSync('./test/apache.pem') } var io = require('socket.io').listen(45621, options) io.sockets.on("connection", function(socket) { console.log("socket " + socket.id + " connected !") }) 客户端:(我正在使用一个简单的HTML客户端) <script src="http://code.jquery.com/jquery-latest.min.js"></script> <script src="socket-io-1-2-1.js"></script> <script> var socket = io.connect('https://localhost:45621', {secure: true}) socket.on("connect", function() { alert("we are […]

与Servlet一起使用Socket.IO

我正在考虑通过WebSocket(我目前使用)在我的项目中使用Socket.IO。 我还没有使用Node.js。 当我试图通过Socket.IO,我得到了Node.js是必须实现这一点的想法。 我有几个问题要问。 是否类似于WebSocket 我可以使用没有Node.js的Socket.IO 我在哪里可以学习使用Servlet的Socket.IO 我是否需要添加单独的库文件来处理Servlet中的Socket.IO(我正在使用Java 8)。 如果是的话,哪一个是正确的。 我正在使用Glass-fish Server。 在我的项目中只使用了hibernate,没有其他的框架被使用,我不熟悉任何其他框架。 我经历了以前在这里问过的这个问题,但我不明白如何使用这个 。 请帮忙

使用Redis和Socket.io在Laravel 5.2中进行事件广播

我把Laravel 5.1更新到5.2,这个事件不再播放。 我正在使用Laravel家园,使用php 7和hhvm,Node 5.3.0,Redis 3.0.6。 Redis工作正常。 (我试过Redis ::发布)。 我解雇了这个事件,但是我没有收到任何消息。 事件类 namespace App\Events; use App\Events\Event; use Illuminate\Queue\SerializesModels; use Illuminate\Contracts\Broadcasting\ShouldBroadcast; class UserSignedUp extends Event implements ShouldBroadcast { use SerializesModels; public $username; /** * Create a new event instance. * * @return void */ public function __construct($username) {print_r($username); $this->username = $username; } /** * Get the channels […]

客户端可以接收事件,但不能发射

我有我的客户这样设置: var socket = io(); socket.on('thing', function(socket){ console.log('A user connected: ' + socket.data); }); function sendThing(){ var data = document.getElementById('myInput').value; console.log(data) socket.emit('message', { message: data }); } 我可以接收事件就好,我有我的服务器发出一个事件,它注销罚款: io.on('connection', (socket) => { io.emit('thing', { data: 'thisisathing' }); }); 编辑:我的on.messagefunction: io.on('message', (socket) => { console.log(socket.message); }); 但是我的服务器从来没有收到消息,因为客户端的发射不会触发。 套接字存在,我没有得到任何错误。 我该如何解决?

使用inversify-express-utils,我怎样才能整合websockets?

我们尝试使用websockets来连接基于inversify-express-utils来扩展我们的打字稿应用程序,但到目前为止还没有运气: import 'reflect-metadata'; import {interfaces, InversifyExpressServer, TYPE} from 'inversify-express-utils'; import { Kernel } from 'inversify'; import {UserController} from './controller/UserController'; import TYPES from './constant/types'; import * as socketIo from 'socket.io'; // set up kernel let kernel = new Kernel(); // create server let server = new InversifyExpressServer(kernel); kernel.bind<interfaces.Controller>(TYPE.Controller).to(UserController).whenTargetNamed(TAGS.UserController); server .build() .listen(3000, 'localhost', () => console.log('listening on […]

如何从routes / index访问io.emit()? 上快递4.15

斌/ www.js var server = http.createServer(app); io = require('socket.io')(server); io.on('connection', function(client) { console.log('Client connected…'); client.on('join', function(data) { console.log(data); }); }); server.listen(port); 在这里我需要通过socket.io访问或发送消息或mongoose结果(我不知道这是可能的或不? 我需要从routes/index.js页面发送消息给客户端。 我试过的是 module.exports.io = io; //(in `bin/www`) 并访问index.js这样的io像这样var io = require('../ bin / www'); io.on('connection', function(client) { console.log('Client connected…'); client.on('join', function(data) { console.log(data); }); }); 但它会有一些错误 io.on('connection', function(client) { ^ TypeError: io.on is […]

在Node.js中使用WebSockets最简单的方法

我想在Node.js Web应用程序中使用WebSockets,我正在寻找最简单的方法来做到这一点。 我看到很多github仓库似乎提供了一些易用性。 但是,我只是想看看是否有一个突出的支持最多,或实施最广泛。 我是倾向于Socket.IO,但我不完全确定。 有什么build议? 谢谢!