一般伺服器端代碼,每次收到一個線程,一個client就會產生:
/************************ 開始監聽 **************************/
int port = 4311;
ServerSocket server = null;//伺服器
Socket client = null;//客戶端
try {
server = new ServerSocket(port);
} catch (IndirectionException e1) {
System.out.println("正在監聽...");
}
while(true)
{
System.out.println("等待客戶" i);
i ;
try {
client = server.accept();//開始監聽線程,接收到client
System.out.println("客戶地址:" client.getInetAddress());
} catch (IOException e1) {
System.out.println("正在等待客戶");
}
}
客戶端代碼,啟動之後便會連接伺服器,得到回應之後便會形成socket連接
Socket clientsocket = null;
try {
clientsocket = new Socket("localhost",4311);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
socket的輸入和輸出一般用流來相互寫.
in.read()和out.write(),
in.readObject()和out.writeObject(object).
客戶端的一個線程裡面同時new了多個ObjectOutputStream流是不允許的,其它的流可以.ObjectOutputStream有鎖機制.
如果是一般的輸入和輸出流的話用:
DateOutputStream out = null;
DateInputStream in = null;
//獲得輸入輸出流
try {
out=new DateOutputStream(socket.getOutputStream());
in=new DateInputStream(socket.getInputStream());
} catch (IOException e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}
如果是對象上的輸入和輸出的話用:
ObjectOutputStream out = null;
ObjectInputStream in = null;
//獲得輸入輸出流
try {
out=new ObjectOutputStream(socket.getOutputStream());
in=new ObjectInputStream(socket.getInputStream());
} catch (IOException e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}
如果複雜之後,可以是伺服器啟動之後對每個客戶端啟動一個線程與客戶端的線程進行交互.
[火星人 ] java關於多線程的部分操作已經有322次圍觀