二話不說，大家先看一下我服務(wù)端添加的引用

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using commands;


注意一下，這里的最后一個引用commands，與客戶端的commands必須是同一個dll，同樣的代碼編譯出來的文件都不行。這是為什么

捏。試想一下，你用一個規(guī)則去序列化一個對象，然后用另一個規(guī)則進(jìn)行反序列化，得到的對象不會是原來的對象了吧。

好，下一步。這里是服務(wù)器端，每一個客戶端連到服務(wù)器，都對應(yīng)一個類的對象，然后把它們搞到一個列表里面。這樣就方便進(jìn)行操作了。在這個基礎(chǔ)上，給客戶端

發(fā)信息，或者轉(zhuǎn)發(fā)一個客戶端的信息給另一個或多個客戶端，都是小case了。

下面就是客戶端對應(yīng)的類了。

public class InConnectUser
{
public TcpClient client { get; set; }
public BinaryReader br { get; set; }
public BinaryWriter bw { get; set; }

public Guid InUseID { get; set; }
public bool IfUserLogin=false;

public Entity.FeeRules obj_enFeeRules = new Entity.FeeRules();
public Entity.InUse obj_enInUse = new Entity.InUse();
public Entity.Computer obj_enComputer = new Entity.Computer();
public Entity.User obj_enUser = new Entity.User();

public InConnectUser(TcpClient client)
{
this.client = client;
NetworkStream networkstream = client.GetStream();
br = new BinaryReader(networkstream);
bw = new BinaryWriter(networkstream);
}
public void Close()
{
br.Close();
bw.Close();
client.Close();
}
}



我這里是和網(wǎng)吧管理相關(guān)的，所以加了很多邏輯方面的東西在里面就不貼出來占篇幅了。大家如果把代碼copy過去發(fā)現(xiàn)出錯，就注釋掉吧。

話不多，看到關(guān)鍵的地方都寫在下面的注釋里面。



//在線用戶列表
private List<TcpHelper.InConnectUser> onlineUserList = new List<TcpHelper.InConnectUser>();
IPAddress localAddress;
private const int port = 51888;
private TcpListener myListener;

//開啟服務(wù)器的按鈕
private void button_StartServer_Click(object sender, EventArgs e)
{
myListener = new TcpListener(localAddress, port);
myListener.Start();
label_status.Text = "開啟";

Thread myThread = new Thread(ListenClientConnect);
myThread.Start();
//timer1.Enabled = true;
button_StartServer.Visible = false;
button_StopServer.Visible = true;
}
//關(guān)閉服務(wù)器的按鈕
private void button_StopServer_Click(object sender, EventArgs e)
{
label_status.Text = "關(guān)閉";
//關(guān)閉服務(wù)器，移除list的用戶。
//for (int i = onlineUserList.Count - 1; i >= 0; i--)
//{
// RemoveOnlineUser(onlineUserList[i]);
//}
myListener.Stop();
button_StartServer.Visible = true;
button_StopServer.Visible = false;
}

/// <summary>
/// 監(jiān)聽連接
/// </summary>
private void ListenClientConnect()
{
TcpClient newClient = null;
while (true)
{
try
{
//停在此處監(jiān)聽連接，如果有新客戶端連接就運行下去
newClient = myListener.AcceptTcpClient();
}
catch (Exception)
{

break;
}
InConnectUser user = new InConnectUser(newClient);
Thread threadReceive = new Thread(ReceiveData);
threadReceive.Start(user);
onlineUserList.Add(user);

}

}



/// <summary>
/// 收消息
/// </summary>
/// <param name="UserState"></param>
private void ReceiveData(object UserState)
{
InConnectUser user = (InConnectUser)UserState;
TcpClient client = user.client;
MessageInfo receiveObject;

while (true)
{
try
{
byte[] bytes = new byte[999];
//停在此處，networkstream流中有新數(shù)據(jù)則讀出
int i = user.br.Read(bytes, 0, 999);
MemoryStream memory = new MemoryStream(bytes);
BinaryFormatter format = new BinaryFormatter();
receiveObject = (MessageInfo)format.Deserialize(memory);
}
catch (Exception)
{
return;
}
switch (receiveObject.CommandsTypes)
{
case CommandsTypes.RequestHowLong:
//這里是我處理各種命令的方法，和這個博客的主題無關(guān)，就不貼出來了。
//處理好之后，就在這個方法里面發(fā)送回應(yīng)給對應(yīng)的客戶端，所以一定要有參數(shù)user
// ManagerHowLong(user);
break;
case CommandsTypes.RequestUserLogin:
// ManagerUserLogin(user, receiveObject);
break;
case CommandsTypes.RequestUserlogout:
// ManagerUserLogout(user);
break;
case CommandsTypes.RequestLogout:
//注意這里是return，本意是如果客戶端的連接要關(guān)閉， 就用跳出循環(huán)
//但是我的是網(wǎng)吧管理，不考慮這種情況，所以就未做處理
return;
case CommandsTypes.RequestModPWD:
// ManagerModPWD(user, receiveObject);
break;
case CommandsTypes.RequestMachineLogin:
// ManagerMachineLogin(user, receiveObject);
break;

case CommandsTypes.RequestTalk:
// ManagerTalk(receiveObject);
break;

default:
break;
}

}

}

/// <summary>
/// 發(fā)消息
/// </summary>
/// <param name="user">發(fā)給誰</param>
/// <param name="userSend">發(fā)送內(nèi)容</param>
private void SendToClient(TcpHelper.InConnectUser user, MessageInfo userSend)
{
try
{
MemoryStream memory = new MemoryStream();
BinaryFormatter format = new BinaryFormatter();
format.Serialize(memory, userSend);
byte[] bytes = memory.ToArray();

user.bw.Write(bytes);
user.bw.Flush();

}
catch (Exception)
{
//發(fā)送失敗
}
}

代碼不多，但是也要花點小時間去看看條理才會清晰。

龍弟弟奉獻(xiàn)，轉(zhuǎn)載請注明出處謝謝。

另外我這里有根據(jù)這個做成的小聊天程序，大家如果有需要可以找我。

http://files.cnblogs.com/salty/tcp.rar



轉(zhuǎn)載于:https://www.cnblogs.com/salty/archive/2011/04/01/2001798.html

總結(jié)

以上是生活随笔為你收集整理的C#.NET 比较好用的tcp通信模板(服务器端篇)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。