我正在开发一个 Java 服务器，两个控制一个 android 在线游戏。
可以将 myserversocket.accept() 的客户端套接字保存在 Client 类的变量中吗？
这非常有用，因为这样，服务器可以在服务器需要时与客户端通信，而在客户端联系服务器时则不能。
我的实际代码是：
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.UUID;
import sal.app.shared.Packet;
public class Server {
private ArrayList<GameSession> games = new ArrayList<GameSession>();
private ArrayList<Client> pendent_clients = new ArrayList<Client>();
private Packet read_packet= new Packet();
private Packet sent_packet = new Packet();
private Socket clientSocket = null;
public static void main(String[] args) throws ClassNotFoundException{
ServerSocket serverSocket = null;
//DataInputStream dataInputStream = null;
//DataOutputStream dataOutputStream = null;
ObjectOutputStream oos=null;
ObjectInputStream ois=null;
Server myServer = new Server();
try {
serverSocket = new ServerSocket(7777);
System.out.println("Listening :7777");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while(true){
try {
myServer.clientSocket = new Socket();
myServer.clientSocket = serverSocket.accept();
myServer.read_packet = new Packet();
myServer.sent_packet = new Packet();
oos = new ObjectOutputStream(myServer.clientSocket.getOutputStream());
ois = new ObjectInputStream(myServer.clientSocket.getInputStream());
//dataInputStream = new DataInputStream(clientSocket.getInputStream());
//dataOutputStream = new DataOutputStream(clientSocket.getOutputStream());
//System.out.println("ip: " + clientSocket.getInetAddress());
//System.out.println("message: " + ois.read());
//dataOutputStream.writeUTF("Hello!");
/*while ((myServer.read_packet = (Packet) ois.readObject()) != null) {
myServer.handlePacket(myServer.read_packet);
break;
}*/
myServer.read_packet=(Packet) ois.readObject();
myServer.handlePacket(myServer.read_packet);
//oos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
if( myServer.clientSocket!= null){
/*try {
//myServer.clientSocket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
}
/*if( ois!= null){
try {
ois.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if( oos!= null){
try {
oos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}*/
}
}
}
public void handlePacket(Packet hp) throws IOException
{
if(hp.getOpCode() == 1)
{
registPlayer(hp);
}
}
public void registPlayer(Packet p) throws IOException
{
Client registClient = new Client(this.clientSocket);
this.pendent_clients.add(registClient);
if(pendent_clients.size() == 2)
{
initAGame();
}
else
{
ObjectOutputStream out=null;
Packet to_send = new Packet();
to_send.setOpCode(4);
out = new ObjectOutputStream(registClient.getClientSocket().getOutputStream());
out.writeObject(to_send);
}
}
public void initAGame() throws IOException
{
Client c1 = pendent_clients.get(0);
Client c2 = pendent_clients.get(1);
Packet to_send = new Packet();
ObjectOutputStream out=null;
GameSession incomingGame = new GameSession(c1,c2);
games.add(incomingGame);
to_send.setGameId(incomingGame.getGameId());
to_send.setOpCode(5);
out = new ObjectOutputStream(c1.getClientSocket().getOutputStream());
out.writeObject(to_send);
out = new ObjectOutputStream(c2.getClientSocket().getOutputStream());
out.writeObject(to_send);
pendent_clients.clear();
}
public Client getClientById(UUID given_id)
{
for(GameSession gs: games)
{
if(gs.getClient1().getClientId().equals(given_id))
{
return gs.getClient1();
}
else if(gs.getClient2().getClientId().equals(given_id))
{
return gs.getClient2();
}
}
return null;
}
}
使用此代码，我得到了这个错误：
java.net.SocketException: Broken pipe
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
at java.io.ObjectOutputStream$BlockDataOutputStream.drain(ObjectOutputStream.java:1847)
at java.io.ObjectOutputStream$BlockDataOutputStream.setBlockDataMode(ObjectOutputStream.java:1756)
at java.io.ObjectOutputStream.writeNonProxyDesc(ObjectOutputStream.java:1257)
at java.io.ObjectOutputStream.writeClassDesc(ObjectOutputStream.java:1211)
at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1395)
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158)
at java.io.ObjectOutputStream.writeFatalException(ObjectOutputStream.java:1547)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:333)
at Server.initAGame(Server.java:146)
at Server.registPlayer(Server.java:120)
at Server.handlePacket(Server.java:106)
at Server.main(Server.java:63)
当第二个客户端连接并且服务器尝试在此代码中的函数 initGame() 中向前一个客户端 1 发送数据包时，会发生此错误：
out = new ObjectOutputStream(c1.getClientSocket().getOutputStream());
out.writeObject(to_send);
我的安卓代码是这样的：
package sal.app;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import sal.app.logic.DataBaseManager;
import sal.app.shared.Packet;
import android.app.Activity;
import android.os.Bundle;
import android.view.Window;
import android.view.WindowManager;
public class MultiPlayerWaitActivity extends Activity{
private DataBaseManager db;
public void onCreate(Bundle savedInstanceState) {
super.requestWindowFeature(Window.FEATURE_NO_TITLE);
super.getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,WindowManager.LayoutParams.FLAG_FULLSCREEN);
super.onCreate(savedInstanceState);
setContentView(R.layout.multiwaitlayout);
db=DataBaseManager.getSalDatabase(this);
db.teste();
try {
db.createDataBase();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Socket socket = null;
ObjectOutputStream outputStream = null;
ObjectInputStream inputStream = null;
//System.out.println("dadadad");
try {
socket = new Socket("192.168.1.4", 7777);
//Game = new MultiPlayerGame(new ServerManager("192.168.1.66"),new Session(), new Player(""));
outputStream = new ObjectOutputStream(socket.getOutputStream());
inputStream = new ObjectInputStream(socket.getInputStream());
//dataOutputStream.writeUTF(textOut.getText().toString());
//textIn.setText(dataInputStream.readUTF());
Packet p = new Packet();
Packet r = new Packet();
p.setOpCode(1);
outputStream.writeObject(p);
/*try {
r=(Packet)inputStream.readObject();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
//while(true){
//dataInputStream = new DataInputStream(clientSocket.getInputStream());
//dataOutputStream = new DataOutputStream(clientSocket.getOutputStream());
//System.out.println("ip: " + clientSocket.getInetAddress());
//System.out.println("message: " + ois.read());
//dataOutputStream.writeUTF("Hello!");
/*while ((r= (Packet) inputStream.readObject()) != null) {
handPacket(r);
break;
}*/
r=(Packet) inputStream.readObject();
handPacket(r);
//oos.close();
//}
/*System.out.println(r.getOpCode());
if(r.getOpCode() == 5)
{
this.finish();
}*/
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/*finally{
if (socket != null){
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (outputStream != null){
try {
outputStream.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (inputStream != null){
try {
inputStream.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}*/ //catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
//}
catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void handPacket(Packet hp)
{
if(hp.getOpCode() == 5)
{
this.finish();
}
this.finish();
}
}
问候