Мобильная версия- Я отправляю данные от двух клиентов на сервер.
- Я сохраняю один клиент в объекте ожидает отправки на сервер другого клиента.
- Сервер отправляет сообщения двум клиентам, но сообщения доходят до клиента, и возникает ошибка сообщения клиента.
Exception in thread "main" java.io.StreamCorruptedException: invalid type code: AC
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1696)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:501)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:459)
at javaapplication4.clint.main(clint.java:57)
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package javaapplication4;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.Serializable;
import java.net.ServerSocket;
import java.net.Socket;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
import static javaapplication4.ThreadServer.ID;
import static javaapplication4.ThreadServer.usersList;
public class ThreadServer implements TecTakInterface {
// public static data [] users =new data[30];
public static List usersList=new ArrayList();
public static long ID=1;
public static void main(String[] args) throws IOException {
final int PORT = 4040;
ServerSocket serverSocket = null;
// ServerSocket serverSocket = new ServerSocket(PORT);
try {
serverSocket = new ServerSocket(PORT);
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("Server started...");
System.out.println("Wating for clients...");
Socket clientSocket=null;
while (true) {
try {
clientSocket = serverSocket.accept();
} catch (IOException e) {
System.out.println("I/O error: " + e);
}
new EchoThread(clientSocket).start();
}
}
@Override
public String Tostring() throws RemoteException {
String a = "";
if(usersList.isEmpty()==false){
for (data s: usersList){
a +="Id : " +s.id+ ", name palyer : " + s.name+" \n";
}}else{
a="0";
}
return a;
}
}
class data {
public long id;
public String name;
public Socket socket;
public int [] paly={1,2,3,4,5,6,7,8,9};
public data(long id,String name,Socket clientSocket){
this.id=id;
this.name=name;
this.socket = clientSocket;
}
void cupy(data p){
this.id=p.id;
this.name=p.name;
// this.paly=p.paly;
this.socket=p.socket;
}
}
class EchoThread extends Thread {
protected Socket socket;
public EchoThread(Socket clientSocket) {
this.socket = clientSocket;
}
@Override
public void run() {
try (
OutputStream out = socket.getOutputStream();
Scanner in = new Scanner(socket.getInputStream());
) {
while (in.hasNextLine()) {
String input = in.nextLine();
ObjectOutputStream oout = new ObjectOutputStream(out);
String a = "";
if(usersList.isEmpty()==false){
for (data s: usersList){
a +="Id : " +s.id+ ", name palyer : " + s.name+" \n";
}}else{
a="0";
}
// a+="\0";
//System.out.println(" client: " + a);
//out.println(a);
oout.writeObject(a);
// oout.close();
data s1= new data(ID,input,socket);
usersList.add(s1); // out.println("waiting for user comming...");
ID++;
final DataInputStream InFromClient = new DataInputStream(socket.getInputStream());
final DataOutputStream OutToClient = new DataOutputStream(socket.getOutputStream());
data playo = new data(s1.id,s1.name,s1.socket);
if(!a.equals("0")){
long idPlayer=(long) InFromClient.readInt();
// long idPlayer = Long.parseLong(in.next());
System.out.println(idPlayer +" ");
for (data s: usersList){
if(s.id==idPlayer){
System.out.println(s.id+" "+ s.name);
// playo.cupy(s);
playo.id=s.id;
playo.name=s.name;
// playo.paly=s.paly;
playo.socket=s.socket;
break;
}
}
System.out.println(playo.id+" ss "+ playo.name);
try (
//out = socket.getOutputStream();
//in = new Scanner(socket.getInputStream());
OutputStream out1 = playo.socket.getOutputStream();
Scanner in1 = new Scanner(playo.socket.getInputStream());
){
ObjectOutputStream oout1 = new ObjectOutputStream(out1);
oout.writeObject("start in x ");
oout.writeObject("the paly start : ");
oout.writeObject("He/she is player x (: ");
`Exception erorr send data to Clint sockat`
oout1.writeObject("the paly start : ");
// oout1 = new ObjectOutputStream(out1);
oout1.writeObject("He/she is player O (: ");
//oout1 = new ObjectOutputStream(out1);
oout1.writeObject("start in x ");
}catch (IOException e) {
System.out.println("erorr111 "+e);
}
}
System.out.println("Received radius from client: " + input);
}
} catch (IOException e) {
System.out.println("erorr"+e);
}
}
}
Почему выдает следующую ошибку? в сохраненном клиенте сокета и отправьте его в другой поток:
package javaapplication4;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
/**
*
* @author 5442
*/
public class clint {
public static void main(String[] args) throws IOException, ClassNotFoundException {
final String HOST = "127.0.0.1";
final int PORT = 4040;
//System.out.println("Client started.");
try (
Socket socket = new Socket(HOST, PORT);
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// Scanner in = new Scanner(socket.getInputStream());
Scanner s = new Scanner(System.in);
InputStream in = socket.getInputStream();
final DataInputStream FromServer = new DataInputStream(socket.getInputStream());
final DataOutputStream ToServer = new DataOutputStream(socket.getOutputStream());
) {
System.out.print("Enter your name : ");
String input = s.nextLine();
out.println(input);
ObjectInputStream oin = new ObjectInputStream(in);
String stringFromServer = (String) oin.readObject();
// System.out.println(in.);
if("0".equals(stringFromServer)){
System.out.println("waiting for user comming...");
}
else{
System.out.println(stringFromServer);
System.out.println("Enter the Id of player");
//System.out.print("Enter your name : ");
int idPalyer = s.nextInt();
System.out.println(idPalyer);
// out.println(idPalyer);
ToServer.writeInt(idPalyer);
// than use ToServer.writeInt() and FromServer.readInt()
}
// ObjectInputStream oin = new ObjectInputStream(in);
// oin.close();
stringFromServer = (String)oin.readObject();
System.out.println(stringFromServer);
stringFromServer = (String) oin.readObject();
System.out.println(stringFromServer);
stringFromServer = (String) oin.readObject();
System.out.println(stringFromServer);
}
}
}
Подробнее здесь: https://stackoverflow.com/questions/686 ... nd-in-anth
