第Java創(chuàng)建多線程局域網(wǎng)聊天室實例SuperSocketsocket_1=newSuperSocket(9999);

SuperSocketsocket_2=newSuperSocket(9998);

SuperSocketsocket_3=newSuperSocket(9997);

Threads1=newThread(socket_1);

Threads2=newThread(socket_2);

Threads3=newThread(socket_3);

5.服務(wù)器

服務(wù)器的架構(gòu)第三部分所示，代碼實現(xiàn)如下

packageTCP;

importjava.io.IOException;

importjava.io.InputStream;

import.ServerSocket;

import.Socket;

importjava.util.Scanner;

publicclassTCPserver2{

publicstaticvoidmain(String[]args){

Scannerscan=newScanner(System.in);

//實例化具有多線程功能的服務(wù)器專用socket類

//需要傳遞端口號作為初始化變量

SuperSocketsocket_1=newSuperSocket(9996);

SuperSocketsocket_2=newSuperSocket(9998);

SuperSocketsocket_3=newSuperSocket(9997);

//建立三個子線程

Threads1=newThread(socket_1);

Threads2=newThread(socket_2);

Threads3=newThread(socket_3);

try{

while(true){

//開啟線程

s1.start();

s2.start();

s3.start();

if(scan.next()=="123"){

//結(jié)束線程

break;

}finally{

try{

//關(guān)閉套接字

socket_1.close();

socket_2.close();

socket_3.close();

}catch(IOExceptione){

e.printStackTrace();

classSuperSocketextendsSocketimplementsRunnable{

InputStreamis;

byte[]buffer;

Socketsocket=null;

ServerSocketserverSocket=null;

publicSuperSocket(intport){

try{

//初始服務(wù)器型套接字

serverSocket=newServerSocket(port);

buffer=newbyte[1024];

}catch(IOExceptione){

e.printStackTrace();

@Override

publicvoidrun(){

try{

//等待端口連接

socket=serverSocket.accept();

//連接完成后創(chuàng)建輸入流

is=socket.getInputStream();

//讀取客戶端傳送信息

intlen=is.read(buffer);

Stringstr=newString(buffer,0,len);

System.out.println(str);

}catch(IOExceptione){

e.printStackTrace();

}

客戶端

客戶端的架構(gòu)第三部分所示，代碼實現(xiàn)如下

packageTCP;

importjava.io.IOException;

importjava.io.OutputStream;

import.InetAddress;

import.Socket;

import.UnknownHostException;

importjava.util.Scanner;

publicclassTCPclient{

publicstaticvoidmain(String[]args){

InetAddressaddress=null;

Socketsocket=null;

OutputStreamos=null;

Stringmessage=null;

Scannersca=null;

try{

//得到本機IP地址

address=InetAddress.getByName("6");

//規(guī)定端口號，建立套接字

intport=9998;

socket=newSocket(address,port);

//綁定套接字的輸出流

os=socket.getOutputStream();

sca=newScanner(System.in);

while(true){

message=sca.next();

//寫入輸出流，在局域網(wǎng)中傳輸

os.write(message.getBytes());

}catch(UnknownHostExceptione){

e.printStackTrace();

}catch(IOExceptione){

e.printStackTrace();

}finally{

try{

//關(guān)閉端口號，關(guān)閉io流

os.close();

socket.close();

}catch(IOExceptione){

e.pr