?? communicate.java
字號:
package test;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Enumeration;
import java.util.Hashtable;
import test.*;
public class Communicate implements Runnable
{
private Socket sockct;
private Hashtable sockets;
private InputStream is;
public Communicate(Socket sockct, Hashtable sockets) throws IOException
{
this.sockct = sockct;
this.sockets = sockets;
is = sockct.getInputStream();
}
public void run()
{
byte[] b = new byte[20];
while(true)
{
try
{
//接收該客戶機(jī)的繪制信息
is.read(b, 0, 20);
Enumeration enumeration = sockets.elements();
while(enumeration.hasMoreElements())
{
Object object = enumeration.nextElement();
Socket socketAllClient = (Socket)object;
if(sockct != socketAllClient)
{
//向其他客戶機(jī)發(fā)送信息
OutputStream osAllClient = socketAllClient.getOutputStream();
osAllClient.write(b, 0, 20);
}
}
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -