Gostaria de tirar uma dúvida em como comunicar 2 servidores, um sendo nodejs e outro sendo java.
Gostaria de transitar informações json entre os 2 utilizando o suporte de socket.
Consegui enviar uma informação do java pra o node e receber la decodificando o base64, mais para enviar outra mensagem do nodejs para o java receber não estou conseguindo.. Alguem pode ajudar?
Código node:
var net = require('net');
var HOST = '127.0.0.1';
var PORT = 6969;
global.Buffer = global.Buffer || require('buffer').Buffer;
function Utf8ArrayToStr(array) {
var out, i, len, c;
var char2, char3;
out = "";
len = array.length;
i = 0;
while(i < len) {
c = array[i++];
switch(c >> 4)
{
case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7:
// 0xxxxxxx
out += String.fromCharCode(c);
break;
case 12: case 13:
// 110x xxxx 10xx xxxx
char2 = array[i++];
out += String.fromCharCode(((c & 0x1F) << 6) | (char2 & 0x3F));
break;
case 14:
// 1110 xxxx 10xx xxxx 10xx xxxx
char2 = array[i++];
char3 = array[i++];
out += String.fromCharCode(((c & 0x0F) << 12) |
((char2 & 0x3F) << 6) |
((char3 & 0x3F) << 0));
break;
}
}
return out;
}
net.createServer(function(sock) {
console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
sock.on('data', function(data) {
console.log(new Buffer(data, 'base64').toString());
console.log(new Buffer('Mensagem recebida com sucesso').toString('base64'));
sock.emit('teste');
});
sock.on('close', function(data) {
console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
});
}).listen(PORT, HOST);
console.log('Server listening on ' + HOST +':'+ PORT);
Código java:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
/**
* Classe Java (client) para Comunicação com servidor NodeJS Escreve e recebe um
* simples "echo" -> "mensagem123" by Douglas.Pasqua http://douglaspasqua.com
*/
public class NodeJsEcho {
// objeto socket
private Socket socket = null;
private static boolean close = false;
public static void main(String[] args) throws UnknownHostException, IOException, ClassNotFoundException {
// instancia classe
NodeJsEcho client = new NodeJsEcho();
// conexão socket tcp
String ip = "127.0.0.1";
int port = 6969;
client.socketConnect(ip, port);
// escreve e recebe mensagem
String message = "mensagem123";
while(!close){
System.out.println("Enviando: " + message);
String retorno = client.echo(message);
System.out.println("Recebendo: " + retorno);
close = true;
}
}
// realiza a conexão com o socket
private void socketConnect(String ip, int port) throws UnknownHostException, IOException {
System.out.println("[Conectando socket...]");
this.socket = new Socket(ip, port);
}
// escreve e recebe mensagem full no socket (String)
public String echo(String message) {
try {
// out & in
PrintWriter out = new PrintWriter(getSocket().getOutputStream(), true);
BufferedReader in = new BufferedReader(new InputStreamReader(getSocket().getInputStream()));
// escreve str no socket e lêr
out.println(message);
String retorno = in.readLine();
return retorno;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
// obtem instância do socket
private Socket getSocket() {
return socket;
}
}
Eu consegui enviar uma mensagem do java para o node e usar um decoder do outro lado, mais ao tentar enviar uma do node js para o java, a mensagem não chega nela, só se eu parar o servidor node e cortar a conexão... acredito que seja no in.readline();
Alguém pode me ajudar?