0

He creado un chat en angular 4 con ayuda de socket.io, fino hasta que los mensajes se envian a todo el mundo, necesito que la coneccion sea usuario con usuario, no de todos con todos(por ahora). He leido q use un nickname pero de verdad que no se con q se come eso..

este es mi index.js

let express = require('express')
let app = express();

let http = require('http');
let server = http.Server(app);

let socketIO = require('socket.io');
let io = socketIO(server);

const port = process.env.PORT || 3000;

io.on('connection', (socket) => {
    console.log('user connected');

    socket.on('new_message', (message) => {
            //socket.emit('new_message',message);
            io.emit('new_message',message);
            console.log( 'el mensaje emitido '+message);
        });

    // socket.on('join-user',(user)=>{

    //  console.log('se unio un usuario'+user);

    // });

    socket.on('disconnect', function(){
        console.log('user disconnected');
    });
});

server.listen(port, () => {
    console.log(`started on port: ${port}`);
});

este el servicio>

import * as io from 'socket.io-client';
import { Observable } from 'rxjs/Observable';

export class ChatService {
    private url = 'http://localhost:3000';
    private socket;

    constructor() {
        this.socket = io(this.url);
    }

    public sendMessage(message) {
        this.socket.emit('new_message', message);
    }

    public getMessages = () => { 
        return Observable.create((observer) => {
            console.log('estoy dentro del servicio, dentro del returnn');
            this.socket.on('new_message', (message) => {
                observer.next(message);
            });
        });
    }


    // public getMessages(message){
    //  return this.socket.on('new_message',message);

    // }

}

y mi componente :

import { Component, OnInit } from '@angular/core';
import { Router, ActivatedRoute, Params } from '@angular/router';
import { RegisterUser,Roles,EditProfile,billetera,Curso} from '../../../model/models';
import { StrService } from '../../../Service/System.service';
import { Subject } from 'rxjs/Rx';
import { ChatService } from './chart.service';


@Component({
    selector: 'chatsView',
    templateUrl: 'chats.component.html',
    providers :[ChatService],
})

export class ChatsViewComponent implements OnInit {
    public data: any=[];
    message: string;
    messages: string[] = [];
    public username;
  constructor(private chatService: ChatService) {
  }

  sendMessage() {

    this.username = sessionStorage.getItem('user');
    this.chatService.sendMessage(this.message);
    this.message = '';

  }

  ngOnInit() { 
    this.chatService.getMessages().subscribe(message=>{
    console.log('dasd'+ message);
    this.messages.push(message);
    //console.log('ChatComponent Initialized '+this.messages+' y los mensajes');
    });
  }
}

1 respuesta 1

1

solo obtienes el id del socket con el que quieres realizar la conversacion y listo yo lo realizo de este modo desde android no debe ser muy diferente en tu lenguaje

io.sockets.connected[id_socket].emit('nuevo mensaje',mensaje);
10
  • como saco el id_socket ?? jeje ese es mi duda que id es ese
    – j.dow
    el 14 sep. 2017 a las 17:23
  • solo ocupas poner socket.id(); con eso se obtiene el id del socket conectado puedes poner un console.log para verificar que id tiene
    – evilshok
    el 14 sep. 2017 a las 17:25
  • Y solo con eso tengo el id del socket???? si imprimo console.log(id_socket); sale el id???
    – j.dow
    el 14 sep. 2017 a las 17:26
  • con poner console.log( socket.id() ); debe de mostrarte el id del socket que se conecto al servidor ya es tu decision como manejarlos o donde guardarlos para luego usarlos
    – evilshok
    el 14 sep. 2017 a las 17:29
  • si ya vi q me devuelve un id tipo token,, ahora bien, si el otro usuario quiere conectarse conmigo solamente por ejemplo?? disculpa mi ingnorancia primera vez q toco esto
    – j.dow
    el 14 sep. 2017 a las 17:33

Tu Respuesta

Al pulsar en “Publica tu respuesta”, muestras tu consentimiento a nuestros términos de servicio, política de privacidad y política de cookies

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.