怎么用多线程实现TCP并行服务器，服务

服务器监听端口 做个无限循环 接到一个连接就创建一个通道线程，并将通道线程存储到一个list集合中

import java.io.BufferedReaderimport java.io.IOExceptionimport java.io.InputStreamReaderimport java.io.PrintWriterimport java.net.ServerSocketimport java.net.Socketimport java.text.SimpleDateFormatimport java.util.ArrayListimport java.util.Dateimport java.util.List/* * 4.用socket通讯写出多个客户端和一个服务器端的通讯， * 要求客户发送数据后能够回显相同的数据（回显功能）（实用TCP方式）。 */public class Test4Server { // 主入口public static void main(String[] args) throws IOException {scoketServer() } // 开启的tcp8888监听端口public static void scoketServer() throws IOException {ServerSocket server = new ServerSocket(8888) while (true) {// 未连通前线程阻塞，连通后开启一个socket通道线程后继续监听8888端口Socket socket = server.accept() System.out.println(socket.getInetAddress().getHostAddress()+ "连接进入") new SocketThread(socket).start() }} } // 一个服务器端口中监听多个客服端通道线程class SocketThread extends Thread {// 所有通道写入流的集合private static List<PrintWriter>list =new ArrayList<PrintWriter>()private BufferedReader bufferedReader private PrintWriter printWriterpublic SocketThread(Socket socket) throws IOException {this.bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream())) this.printWriter = new PrintWriter(socket.getOutputStream()) list.add(printWriter) } @Overridepublic void run() {String string = null while (true) {try {// 服务器在通道中读到的信息回显给客服端string = bufferedReader.readLine() System.out.println("客服端信息：" + string) for(PrintWriter printWriter:list ){printWriter.write("服务器回显：" + string + "\r\n") printWriter.flush() }} catch (IOException e) { }} }}

TCP在真正的读写操作之前，server与client之间必须建立一个连接，

当读写操作完成后，双方不再需要这个连接时它们可以释放这个连接，

连接的建立通过三次握手，释放则需要四次握手，

所以说每个连接的建立都是需要资源消耗和时间消耗的。

用C#实现多线程TCP协议的服务器端程序：

// <summary>

/// Tcp客户线程类（服务端），ThreadServerProcessor 线程产生的客户连接，用该线程读写

/// </summary>

public class ThreadClientProcessor

{

//Tcp连接实例

private TcpClient tcpClient

//消息框，本来想写日志用

private System.Windows.Forms.ListBox MessageList

private string Password//该连接登陆密码

private string Cmd1Echo

private string Cmd2Echo

private bool ClientLogOn//客户是否登陆

private bool TcpClose

public ThreadClientProcessor(){}

//构造函数，参数解释：Tcp客户，消息框，该服务密码（password命令后的参数） ,命令回应串 1,2 ******************

public ThreadClientProcessor(TcpClient client , ListBox listBox,string LogonText ,string cmd1echo,string cmd2echo)

{

ClientList.Add(this) //把当前实例加入一个列表中，方便以后控制

this.tcpClient=client

this.MessageList=listBox

this.Password=LogonText

this.Cmd1Echo=cmd1echo

this.Cmd2Echo=cmd2echo

this.ClientLogOn=false

this.TcpClose=false

}

public static char[] CmdSplit={' '}//读来的串由' ' 进行分离，命名+' '+参数

//public const string[] Cmd=new string[] { "password","cmd1","cmd2","echo","bye"}

//该函数由你自己写，这个只是给一个例子，

//功能：命令处理器，给个命令串，返回该命令处理结果，把命令和处理结果放在一个文本文件里，便于系统升级

public string TcpCmd(string s)

{

string result

try

{

string cmdarg=s.Trim()

string[] args=cmdarg.Split(CmdSplit)

string cmd=args[0].ToLower()

switch (cmd )

{

case "password" :

if (args.Length>1)

{

ClientLogOn= Password.Equals(args[1].Trim())

result=ClientLogOn? "登陆成功":"密码不正确，未登陆"

}

else result= "登陆时候，没有输入密码"

break

case "cmd1":

result=ClientLogOn?this.Cmd1Echo:"该命令无权执行，请先登陆"

break

case "cmd2":

result=ClientLogOn?this.Cmd2Echo:"该命令无权执行，请先登陆"

break

case "echo":

result=string.Format("服务器回应：\n {0}",s)

break

case "bye":

this.TcpClose=true

result="DisConnected"

break

default:

result="不可识别的命令"

break

}

}

catch

{

result="解析命令发生错误,你输入的是狗屁命令，TMD *^* "

}

return result

} //end cmd

//定义一个线程，该线程对应的函数是 void start（）（不是Start（））********************************

//一下程序主要是操作该线程

public System.Threading.Thread tcpClientThread

//启动客户连接线程 *************************************************************

public void Start()

{

tcpClientThread=new Thread(new ThreadStart(start))

tcpClientThread.Priority=ThreadPriority.BelowNormal

tcpClientThread.Start()

}

//断开该当前实例连接，终止线程 **************************************************************

public void Abort()

{

if (this.tcpClientThread!=null)

{

//tcpClientThread.Interrupt()

tcpClientThread.Abort()

//一定要等一会儿，以为后边tcpClient.Close（）时候，会影响NetWorkStream的操作

Thread.Sleep(TimeSpan.FromMilliseconds(100))

tcpClient.Close()

}

}

//静态列表，包含了每个连接实例（在构造实例时候使用了 ArrayList.Add( object)）

private static System.Collections.ArrayList ClientList=new ArrayList()

//断开所有的Tcp客户连接，静态方法*************************************************************

public static void AbortAllClient()

{

for(int j=0 j<ClientList.Countj++)

{

//从实例列表中取一个对象，转化为ThreadClientProcessor对象

ThreadClientProcessor o=(ThreadClientProcessor ) ClientList[j]

//调用ThreadClientProcessor 对象的停止方法

o.Abort()

}

//清除连接列表

ClientList.Clear()

}

//读写连接的函数，用于线程//*******************************************************************

private void start()

{

byte[] buf=new byte[1024*1024]//预先定义1MB的缓冲

int Len=0//流的实际长度

NetworkStream networkStream=tcpClient.GetStream()//建立读写Tcp的流

try

{

byte[] p=Encoding.UTF8.GetBytes(" 欢迎光临，请输入密码" )

//向Tcp连接写 欢迎消息

if (!this.ClientLogOn )

networkStream.Write(p,0,p.Length)

//开始循环读写tcp流

while (!TcpClose)

{

//如果当前线程是在其它状态，（等待挂起，等待终止.....)就结束该循环

if (Thread.CurrentThread.ThreadState!=ThreadState.Running)

break

//判断Tcp流是否有可读的东西

if ( networkStream.DataAvailable)

{

//从流中读取缓冲字节数组

Len=networkStream.Read(buf,0,buf.Length)

//转化缓冲数组为串

string cmd=Encoding.UTF8.GetString(buf,0,Len)

this.MessageList.Items.Add("客户机："+cmd)

//处理该缓冲的串（分析命令）,分析结果为res串

string res=TcpCmd(cmd)

//把命令的返回结果res 转化为字节数组

byte[] result=Encoding.UTF8.GetBytes(res)

//发送结果缓冲数组给客户端

networkStream.Write(result,0,result.Length)

this.MessageList.Items.Add("服务器回应:"+res)

}

else

{

//Thread.Sleep(TimeSpan.FromMilliseconds(200d))

//this.MessageList.Items.Add("客户机无命令")

//如果当前Tcp连接空闲，客户端没有写入，则当前线程停止200毫秒

Thread.Sleep(TimeSpan.FromMilliseconds(200d))

}

}

---