teen eka serverin ja otan ikuisessa loopissa vastaan yhteyksiä (tää luokka on Thread)
SocketServer listener = new SocketServer(12345);
while(true)
{
Thread th = new Thread(
new ClientWorker(listener.accept()));
th.start();
}
Jokaista yhteyttä varten luodaan toinen Threadi ClientWorker, joka hoitaa input/outputin sen yhdistävän pään kanssa.
ClientWorker avaa konstruktorissa saamaansa sockettiin inputstreamin ja outputstreamin.
BufferedReader in = null;
PrintWriter out = null;
try{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);
} catch (IOException e) {
System.out.println("in or out failed");
System.exit(-1);
}
Jos telnettaan toiselta koneelta tähän porttiin, niin ClientWorker saa kaiken näpyttelemäni tekstin ihan ok ja se lähettää kamaa ihan ok vastapäälle.
Sitten jos luonkin javalla clientin samalla koneella missä serveri on, niin tämä clientti ei saa lähetettyä mitään serverille, eikä ClientWorker vastaanota/lähetä mitään tälle local clientille. Accept() palauttaa socketin ClientWorkerille tässäkin tapauksessa ja client saa luotua socketin ihan ok. Missään välissä ei mitään exceptionia tule.
ClientWorker saa siis socketin serverin accept() metodilta ja client luo itse socketin Socket("127.0.0.1", 12345);
Menevätkö socketin inputstream ja outputstream jotenkin ristiin, kun socket näyttää olevan sama sekä Client-workerissä ja itse local clientissä? Molempien socketit näyttävät samat portit getPort() ja getLocalPort() metodeilla.
Miten tämä serveri pitää oikeen rakentaa, että myös samalla koneella pyörivä client saa välitettyä/vastaanotettua dataa?
2 päivää googlettanut ja ei ole löytynyt vastausta. En luullut local clientin olevan edes ongelma, kun siitä ei puhuttu missään artikkelissa.
SocketServer listener = new SocketServer(12345);
while(true)
{
Thread th = new Thread(
new ClientWorker(listener.accept()));
th.start();
}
Jokaista yhteyttä varten luodaan toinen Threadi ClientWorker, joka hoitaa input/outputin sen yhdistävän pään kanssa.
ClientWorker avaa konstruktorissa saamaansa sockettiin inputstreamin ja outputstreamin.
BufferedReader in = null;
PrintWriter out = null;
try{
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);
} catch (IOException e) {
System.out.println("in or out failed");
System.exit(-1);
}
Jos telnettaan toiselta koneelta tähän porttiin, niin ClientWorker saa kaiken näpyttelemäni tekstin ihan ok ja se lähettää kamaa ihan ok vastapäälle.
Sitten jos luonkin javalla clientin samalla koneella missä serveri on, niin tämä clientti ei saa lähetettyä mitään serverille, eikä ClientWorker vastaanota/lähetä mitään tälle local clientille. Accept() palauttaa socketin ClientWorkerille tässäkin tapauksessa ja client saa luotua socketin ihan ok. Missään välissä ei mitään exceptionia tule.
ClientWorker saa siis socketin serverin accept() metodilta ja client luo itse socketin Socket("127.0.0.1", 12345);
Menevätkö socketin inputstream ja outputstream jotenkin ristiin, kun socket näyttää olevan sama sekä Client-workerissä ja itse local clientissä? Molempien socketit näyttävät samat portit getPort() ja getLocalPort() metodeilla.
Miten tämä serveri pitää oikeen rakentaa, että myös samalla koneella pyörivä client saa välitettyä/vastaanotettua dataa?
2 päivää googlettanut ja ei ole löytynyt vastausta. En luullut local clientin olevan edes ongelma, kun siitä ei puhuttu missään artikkelissa.
Vastaukset 3
Vanhimmat
Eli jos telnettaan tähän serveriin, nii toimii ok, mutta toi local client ei toimi ei millään.
import java.net.*;
import java.io.*;
public class Server extends Thread
{
private ServerSocket listener;
public Server()
{
try
{
listener = new ServerSocket(12345);
Thread th = new Thread(this);
th.start();
}
catch (Exception e)
{
e.printStackTrace();
}
}
public void run()
{
try
{
System.out.println("Server starting to listen...");
while(true)
{
Thread th = new Thread(new ClientWorker(listener.accept()));
th.start();
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
public static void main(String [] args)
{
Server serveri = new Server();
Client asiakas = new Client();
}
}
-----
import java.net.*;
import java.io.*;
public class Client
{
private Socket server;
private BufferedWriter out;
private BufferedReader in;
public Client()
{
String host = null;
try {
this.server = new Socket(host, 12345);
System.out.println("Client got connection to server...");
out = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));
in = new BufferedReader(new InputStreamReader(server.getInputStream()));
}
catch (Exception e)
{
e.printStackTrace();
}
String str;
try {
System.out.println("Client writing to socket...");
out.write("HELLO");
out.flush();
while ((str = in.readLine()) != null)
{
System.out.println("Client reading from socket...");
System.out.println("Client got: " str);
}
in.close();
out.close();
server.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
-----
import java.net.*;
import java.io.*;
public class ClientWorker extends Thread
{
private Socket server;
private BufferedWriter out;
private BufferedReader in;
public ClientWorker(Socket server)
{
System.out.println("new ClientWorker for connection!");
this.server = server;
}
public void run()
{
String str;
try {
out = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));
in = new BufferedReader(new InputStreamReader(server.getInputStream()));
System.out.println("ClientWorker saying hello...");
out.write("HELLO CLIENT");
out.flush();
System.out.println("ClientWorker waiting for input...");
while ((str = in.readLine()) != null)
{
System.out.println("ClientWorker got input, writing to socket...");
out.write("ECHO..." str);
out.flush();
}
in.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
Ongelmasi on rivinvaihdossa jotta et lähetä, jolloin kumpikin (serveri ja client) pysähtyy readLine käskyyn. Korjaukset ovat siis:
...
out.write("HELLO\n");
...
out.write("HELLO CLIENT\n");
...
out.write("ECHO..." str "\n");
...
kiitoksia avusta!