Трябва да внедря изпращане на данни с конкретен порт източник и в същото време да слушам този порт. Пълен дуплекс. Някой знае ли как да го внедри на java. Опитах се да създам отделна нишка за слушане на входен поток на сокет, но не работи. Не мога да свържа ServerSocket и клиентския сокет към един и същ порт източник и същото с netty. Има ли някакво решение за скучен дуплекс?
init(){
socket = new Socket(InetAddress.getByName(Target.getHost()), Target.getPort(), InetAddress.getByName("localhost"), 250);
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
}
private static void writeAndFlush(OutputStream out, byte[] b) throws IOException {
out.write(b);
out.flush();
}
public class MessageReader implements Runnable {
@Override
public void run() {
//this method throw exception EOF
read(in);
}
private void read(DataInputStream in){
while (isConnectionAlive()) {
StringBuffer strBuf = new StringBuffer();
byte[] b = new byte[1000];
while ((b[0] = bufferedInputStream.read(b)) != 3) {
strBuf.append(new String(b));
}
log.debug(strBuf.toString());
}
}
}
yourпорт.. вие пишете на порта на целевата машина, освен ако не казвате, че пишете на себе си? Започнете със Слушателя... - person T McKeown schedule 01.07.2014