core:
On the two Socket instances of the server and client, we need a fixed serverSocket with a specific port number to listen to the application of remote clientSocket and establish a corresponding proxSocket for this application for this application.
Server maintenance:
serverSocket
| Server instance | Client instance | relation |
|---|---|---|
| proxSocket | clientSocket | One by one |
1. There must be a service side
--Configuration-
1、new Socket
Socket serverSocket = new Socket(, , );
2、Bind
(new IPEndPoint((txtIP), (txtPost))); //The server binds native IP and port
3、Listen
(10); //The maximum number of connections is 10
4、Accept
Socket proxSocket = (); // Listen to Socket connection behavior and create Socket instances for the listened link, which will block the thread until the port link
--Information sending and transmission-
5、Receive
(data, 0, , ); //data is the byte array to be written to, which blocks the thread until the Send of the slientSocket is heard and continues until the end of IO
6、Send
(result, 0, , ); //result is the byte array to be uploaded
2. There is also a client
--Configuration-
1、new Socet
ClientSocket = new Socket(, , );
2、Connect
(new IPEndPoint((txtIP), (txtPort))); //Try to link the corresponding IP and port of the server. After the connection is successful, the server side creates a specific proxSocket for information exchange
--Information sending and transmission-
3
(data, 0, , );
4
(result, 0, , );
using System;
using;
using;
using;
namespace SockerDamo
{
class SocketServer
{
List<Socket> ClientProxSocketList = new List<Socket>();// Used to store client links
Socket ServerSocket { get; set; }
public void Start()//Create a server Socket, start listening to the client, and start receiving messages in a loop
{
//1. Create a socket object
Socket serverSocket = new Socket(, , );
ServerSocket = serverSocket;
//first is addressing method (Ipv4 here)
//second is the socket's type
//And the thrid is the transmission protocol
("Please enter the IP address:");
String txtIP = ();
("Please enter the port number:");
String txtPost = ();
//2. Bind the port IP
(new IPEndPoint((txtIP), (txtPost)));
//socket's Bind action need a IPEndPoint to bind the socket and the computer's ip and post
//so in the IPEndPoint we need a IPAddress and a int number(Post)
//3. Start listening
(20);//the number indicates the maximum limit number of queues simultaneously
//There are 100 link requests at the same time, and only one link can be processed. There are 20 clients waiting for links in the queue, and the others return error messages.
//4. Start accepting client links
//In order not to block the main thread, we should put the following code in a new thread (pool)
try
{
("Start listening to link...");
Socket proxSocket = ();//This method will block the current thread until the link is heard
AppendTextToTxtLog(("Client {0} linked", ()));
byte[] data = new byte[1024 * 1024 * 256];//Array used to put data
int len;
While (true)
{
("Please select mode:");
("0. Waiting for receiving the message");
("1.Send a message");
string mo = ();
//Get client data and return the number of bytes read, it will block the current thread.
// When the client suddenly drops, an exception will often be caused
if (mo == "0")
{
try
{
len = (data, 0, , );//In the data array, starting from index=0, the maximum write data length is
if (data[0] == 0)
{
StopConnect(proxSocket);
}//Normal exit logic
else if (data[0] == 1)
{
string str = Encoding.(data, 1, len - 1);//In the data array, start from 0, len data, convert it to str
AppendTextToTxtLog(("The information received by the client:{0} is: {1}", (), str));
}
}
catch (Exception)
{
("An error occurred when receiving data");
StopConnect(proxSocket);
}
}
else if (mo == "1")
{
SendMsg();
}
}
}
catch
{
AppendTextToTxtLog("There is a problem: When you receive the client's request, an exception occurred and died of ```");
}
}
private void StopConnect(Socket proxSocket)//Stop link
{
try
{
if ()
{
();
(100);
}
}
catch (Exception ex)
{
("Maybe no successful stop of connection" + ());
}
}
//Send a message
private void SendMsg()
{
String txtMsg = ();
foreach (var proxSocket in ClientProxSocketList)
{
if ()
{
byte[] data = Encoding.(txtMsg);//Information is converted to binary
byte[] result = new byte[ + 1];//The binary of the information is placed in 1~
result[0] = 1;//The 0th position is the flag bit. In the future, we can use this flag bit to distinguish the file type and use it to pass files in the future.
(data, 0, result, 1, );//Turn data from 0 result from 1 length
(result, 0, , );//Send a message
}
}
AppendTextToTxtLog(("{0}(native) information is: {1}", (), txtMsg));
}
private void AppendTextToTxtLog(string txt)
{
(txt);
}
}
class SocketClient
{
Socket ClientSocket { get; set; }
public void Start()//Create a client socket and start receiving messages in a loop
{
#region Get server port content
("Please enter the server IP:");
String txtIP = ();
("Please enter the port number:");
String txtPort = ();
#endregion
//Client link server
//1. Create Socket object
ClientSocket = new Socket(, , );
//2. Connect to the server-side Socket
try//If the server's Listen queue is full, an exception will be returned
{
(new IPEndPoint((txtIP), (txtPort)));
}
catch
{
("The current server cannot be connected");
//(1000);
return;
}
//3. Receive server-side messages
byte[] data = new byte[1024 * 1024 * 256];//The data is transferred here, here is 256MB = 256 * 1024 KB = 256 * 1024 * 1024Byte
int len;
string str;
string wenJianMing = "";
While (true)
{
("Please select mode:");
("0. Waiting for receiving the message");
("1.Send a message");
string mo = ();
len = 0;
str = null;
if (mo == "0")
try
{
len = (data, 0, , );//Get server-side data and return the number of bytes read, which will block the current thread.
// When the client suddenly drops, an exception will often be caused
if (data[0] == 0)//Mode 0 exit
{
AppendTextToTxtLog(("Server:{0} Normal Exit", ()));
StopConnect();
}
else if (data[0] == 1)
{//Standle received by pattern 1
str = Encoding.(data, 1, len - 1);
AppendTextToTxtLog(("Socket information:{0}", str));
}
//Analogous, there are 256 messages transmission modes in total
}
catch (Exception)
{
AppendTextToTxtLog(("Server:{0} abnormal exit",
()));
StopConnect();
return;
}
else if(mo == "1"){
SendMsg();
}
}
// You can also write step 3 to the method ReceiveData
// Thread thread = new Thread(new ParameterizedThreadStart(ReceiveData));
// = true;
// (); // Then start the thread
}
private void AppendTextToTxtLog(string txt)
{
(txt);
}
private void StopConnect()
{
try
{
if ()
{
();
(100);
}
}
catch (Exception ex)
{
("Maybe no successful stop of connection" + ());
}
}
public void SendMsg()
{
if ()
{
("Please enter the mode of the message to be sent:");
("0: end");
("1: string");
String ms = ();
if (ms == "0") { }
if (ms == "1")
{
("Please enter the message to be sent:");
String s = ();
byte[] data = Encoding.(s);
byte[] result = new byte[ + 1];//The binary of the information is placed in 1~
result[0] = 1;//The 0th position is the flag bit. In the future, we can use this flag bit to distinguish the file type and use it to pass files in the future.
(data, 0, result, 1, );//Turn data from 0 result from 1 length
(result, 0, , );//Send a message
AppendTextToTxtLog(("Native information is: {0}", s));
}
}
}
}
internal class Program
{
static void Main(string[] args)
{
("0: server side");
("1: Client");
string ms = ();
if (ms == "0")
{
SocketServer server = new SocketServer();
();
}
else if (ms == "1")
{
SocketClient client = new SocketClient();
();
}
}
}
}