Может ли многопоточный сервер пересылать данные на сервер(который принимает один клиент)?
I am trying to forward data from multithreaded server to single clients server. The process like=> Clients >>> Multithread Server >>>> server (which accept only one client)
Что я уже пробовал:
import java.net.*;
import java.io.*;
public class Client
{
// initialize socket and input output streams
private Socket sockett = null;
private DataInputStream inputt = null;
private DataOutputStream outt = null;
private DataInputStream Innn = null;
// constructor to put ip address and port
@SuppressWarnings("deprecation")
public Client(String address, int port)throws IOException
{
// establish a connection
try
{
sockett = new Socket(address, port);
System.out.println("Connected");
// takes input from terminal
inputt = new DataInputStream(System.in);
// sends output to the socket
outt = new DataOutputStream(sockett.getOutputStream());
Innn=new DataInputStream(
new BufferedInputStream(sockett.getInputStream()));
}
catch(UnknownHostException u)
{
System.out.println(u);
}
catch(IOException i)
{
System.out.println(i);
}
// string to read message from input
String line = "";
// keep reading until "Over" is input
while (!line.equals("Over"))
{
try
{
line = inputt.readLine();
outt.writeUTF(line);
line = Innn.readUTF();
System.out.println(line);
}
catch(IOException i)
{
System.out.println(i);
}
}
// close the connection
try
{
inputt.close();
outt.close();
sockett.close();
Innn.close();
}
catch(IOException i)
{
System.out.println(i);
}
}
public static void main(String args[]) throws IOException
{
@SuppressWarnings("unused")
Client client = new Client("127.0.0.1", 5056);
}
}
Многопоточный сервер
public class server
{
public static void main(String[] args) throws IOException
{
// server is listening on port 5056
@SuppressWarnings("resource")
ServerSocket ss = new ServerSocket(5056);
// running infinite loop for getting
// client request
while (true)
{
Socket s = null;
Socket socket= null;
Socket socket1= null;
DataInputStream inn= null;
DataOutputStream outt= null;
DataInputStream in =null;
DataOutputStream out=null;
try
{
// socket object to receive incoming client requests
socket = ss.accept();
System.out.println("A new client is connected : " + s);
// obtaining input and out streams
in = new DataInputStream(
new BufferedInputStream(socket.getInputStream()));
socket1 = new Socket("127.0.01", 5001);
System.out.println("Connected");
out = new DataOutputStream(socket1.getOutputStream());
inn = new DataInputStream(
new BufferedInputStream(socket1.getInputStream()));
outt = new DataOutputStream(socket.getOutputStream());
System.out.println("Assigning new thread for this client");
// create a new thread object
Thread t = new ClientHandler(in,inn,outt,out);
// Invoking the start() method
t.start();
}
catch (Exception e){
socket.close();
e.printStackTrace();
}
}
}
}
// ClientHandler class
class ClientHandler extends Thread
{
DataInputStream in = null;
DataInputStream inn = null;
DataOutputStream out = null;
DataOutputStream outt = null;
// Constructor
public ClientHandler(DataInputStream in, DataInputStream inn, DataOutputStream out, DataOutputStream outt)
{
this.in = in;
this.inn = inn;
this.out = out;
this.outt= outt;
}
@Override
public void run()
{
String line="";
while (true)
{
try {
while (!line.equals("Over"))
{
line = in.readUTF();
System.out.println(line);
out.writeUTF(line);
line = inn.readUTF();
System.out.println(line);
outt.writeUTF(line);
}}
catch(IOException i)
{
System.out.println(i);
}
}
}} Серверimport java.net.*;
import java.io.*;
public class Serever2
{
//initialize socket and input stream
private Socket socket1 = null;
private ServerSocket server2 = null;
private DataInputStream in1 = null;
private DataInputStream input = null;
private DataOutputStream out1 = null;
// constructor with port
public Serever2(int port)throws IOException
{
// starts server and waits for a connection
try
{
server2 = new ServerSocket(port);
System.out.println("Server started");
System.out.println("Waiting for a client ...");
socket1 = server2.accept();
System.out.println("Client accepted");
// takes input from the client socket
in1 = new DataInputStream(
new BufferedInputStream(socket1.getInputStream()));
input = new DataInputStream(System.in);
out1 = new DataOutputStream(socket1.getOutputStream());
String line = "";
// reads message from client until "Over" is sent
while (!line.equals("Over"))
{
try
{
line = in1.readUTF();
System.out.println(line);
out1.writeUTF("Thank you");
}
catch(IOException i)
{
System.out.println(i);
}
}
System.out.println("Closing connection");
// close connection
socket1.close();
in1.close();
input.close();
out1.close();
}
catch(IOException i)
{
System.out.println(i);
}
}
public static void main(String args[]) throws IOException
{
@SuppressWarnings("unused")
Serever2 server = new Serever2(5001);
}
}
Richard MacCutchan
Это целая куча кода, но вы не объяснили, в чем заключается проблема и где она возникает.
FerdouZ
Я не могу преобразовать данные многопоточного сервера в сервер, который я получаю от клиентов, и проблема в многопоточной серверной программе.
Richard MacCutchan
Извините, но это нам ни о чем не говорит.
Arthur V. Ratz
Фердуз, вот мое решение ниже.