Hej udviklere.
Jeg har en C++ server som kan udfører nogle funktioner hvis den modtager en speciel kommando.
Men jeg har fundet en socketserver i C# som jeg vil ændre på, men problemet er at, jeg ikke ved hvordan man laver det i C#.
Den skal altså udfører de samme funktioner som i min C++ server, når den modtager en speciel streng/signal.
Fra min C++ server:
void HandleRx()
{
const int MaxLineLength = 256;
char buffer[MaxLineLength + 1];
sockaddr_in RxSockAddr;
int FromLen = sizeof(RxSockAddr);
if(recvfrom(Socket, buffer, MaxLineLength, 0, (sockaddr *)&RxSockAddr, &FromLen) != SOCKET_ERROR)
{
RxAddr = RxSockAddr.sin_addr;
HasRxAddr = true;
std::cout << "Received: " << buffer << std::endl;
if(!strcmp(buffer, "Restart"))
{
HandleTx("Received The Restart Message");
std::cout << "Try To Close" << std::endl;
Sleep(1000);
Restart();
}
else if(!strcmp(buffer, "Shutdown"))
{
HandleTx("Received Shutdown Command");
Sleep(1000);
Shutdown();
}
else if(!strcmp(buffer, "CDTray Open"))
{
HandleTx("Received CD Tray Open Command");
CDtrayOpen();
}
else if(!strcmp(buffer, "CDTray Close"))
{
HandleTx("Received CD Tray Close Command");
CDtrayClose();
}
else if(!strcmp(buffer, "Oops"))
{
HandleTx("Received Oops Command");
DLGBOX();
}
else if(!strcmp(buffer, "Monitor Off"))
{
HandleTx("Received Monitor Off Command");
MoniOff();
}
else if(!strcmp(buffer, "Alive"))
{
HandleTx("I am alive!");
}
else
{
HandleTx("Message Was Received");
}
}
else
{
std::cout << "Failed To Receive: " << WSAGetLastError() << std::endl;
exit(1);
}
}Nogle funktioner:
void MoniOff()
{
ShellExecute(0, "Open", "003.exe", 0, 0, SW_SHOW);
}
void CDtrayOpen()
{
ShellExecute(0, "Open", "001.exe", 0, 0, SW_SHOW);
}
void CDtrayClose()
{
ShellExecute(0, "Open", "002.exe", 0, 0, SW_SHOW);
}
void DLGBOX()
{
MessageBox(NULL, "Gad vide hvor jeg kommer fra hva'? ;)", "hmm?", MB_OK);
}C# serveren:
using System;
using System.Drawing;
using System.Collections;
using System.ComponentModel;
using System.Windows.Forms;
using System.Data;
using System.Net;
using System.Net.Sockets;
namespace SocketServer
{
/// <summary>
/// Summary description for Form1.
/// </summary>
public class Form1 : System.Windows.Forms.Form
{
public AsyncCallback pfnWorkerCallBack ;
public Socket m_socListener;
public Socket m_socWorker;
private System.Windows.Forms.GroupBox groupBox1;
private System.Windows.Forms.Label label1;
private System.Windows.Forms.TextBox txtPortNo;
private System.Windows.Forms.Button cmdListen;
private System.Windows.Forms.TextBox txtDataRx;
private System.Windows.Forms.GroupBox groupBox2;
private System.Windows.Forms.GroupBox groupBox3;
private System.Windows.Forms.TextBox txtDataTx;
private System.Windows.Forms.Button button1;
/// <summary>
/// Required designer variable.
/// </summary>
private System.ComponentModel.Container components = null;
public Form1()
{
//
// Required for Windows Form Designer support
//
InitializeComponent();
//
// TODO: Add any constructor code after InitializeComponent call
//
}
/// <summary>
/// Clean up any resources being used.
/// </summary>
protected override void Dispose( bool disposing )
{
if( disposing )
{
if (components != null)
{
components.Dispose();
}
}
base.Dispose( disposing );
}
#region Windows Form Designer generated code
/// <summary>
/// Required method for Designer support - do not modify
/// the contents of this method with the code editor.
/// </summary>
private void InitializeComponent()
{
this.groupBox1 = new System.Windows.Forms.GroupBox();
this.cmdListen = new System.Windows.Forms.Button();
this.txtPortNo = new System.Windows.Forms.TextBox();
this.label1 = new System.Windows.Forms.Label();
this.txtDataRx = new System.Windows.Forms.TextBox();
this.groupBox2 = new System.Windows.Forms.GroupBox();
this.button1 = new System.Windows.Forms.Button();
this.txtDataTx = new System.Windows.Forms.TextBox();
this.groupBox3 = new System.Windows.Forms.GroupBox();
this.groupBox1.SuspendLayout();
this.groupBox2.SuspendLayout();
this.SuspendLayout();
//
// groupBox1
//
this.groupBox1.Controls.AddRange(new System.Windows.Forms.Control[] {
this.cmdListen,
this.txtPortNo,
this.label1});
this.groupBox1.Location = new System.Drawing.Point(8, 16);
this.groupBox1.Name = "groupBox1";
this.groupBox1.Size = new System.Drawing.Size(264, 48);
this.groupBox1.TabIndex = 0;
this.groupBox1.TabStop = false;
this.groupBox1.Text = "Settings";
//
// cmdListen
//
this.cmdListen.Location = new System.Drawing.Point(144, 16);
this.cmdListen.Name = "cmdListen";
this.cmdListen.Size = new System.Drawing.Size(104, 24);
this.cmdListen.TabIndex = 2;
this.cmdListen.Text = "Start Listening";
this.cmdListen.Click += new System.EventHandler(this.cmdListen_Click);
//
// txtPortNo
//
this.txtPortNo.Location = new System.Drawing.Point(96, 16);
this.txtPortNo.Name = "txtPortNo";
this.txtPortNo.Size = new System.Drawing.Size(40, 20);
this.txtPortNo.TabIndex = 1;
this.txtPortNo.Text = "8221";
//
// label1
//
this.label1.Location = new System.Drawing.Point(16, 16);
this.label1.Name = "label1";
this.label1.Size = new System.Drawing.Size(72, 16);
this.label1.TabIndex = 0;
this.label1.Text = "Port Number:";
//
// txtDataRx
//
this.txtDataRx.Location = new System.Drawing.Point(8, 264);
this.txtDataRx.Multiline = true;
this.txtDataRx.Name = "txtDataRx";
this.txtDataRx.ScrollBars = System.Windows.Forms.ScrollBars.Vertical;
this.txtDataRx.Size = new System.Drawing.Size(272, 80);
this.txtDataRx.TabIndex = 1;
this.txtDataRx.Text = "";
//
// groupBox2
//
this.groupBox2.Controls.AddRange(new System.Windows.Forms.Control[] {
this.button1,
this.txtDataTx});
this.groupBox2.Location = new System.Drawing.Point(8, 72);
this.groupBox2.Name = "groupBox2";
this.groupBox2.Size = new System.Drawing.Size(272, 152);
this.groupBox2.TabIndex = 2;
this.groupBox2.TabStop = false;
this.groupBox2.Text = "Send Data";
//
// button1
//
this.button1.Location = new System.Drawing.Point(16, 120);
this.button1.Name = "button1";
this.button1.Size = new System.Drawing.Size(232, 24);
this.button1.TabIndex = 1;
this.button1.Text = "Send";
this.button1.Click += new System.EventHandler(this.button1_Click);
//
// txtDataTx
//
this.txtDataTx.Cursor = System.Windows.Forms.Cursors.IBeam;
this.txtDataTx.Location = new System.Drawing.Point(8, 16);
this.txtDataTx.Multiline = true;
this.txtDataTx.Name = "txtDataTx";
this.txtDataTx.ScrollBars = System.Windows.Forms.ScrollBars.Vertical;
this.txtDataTx.Size = new System.Drawing.Size(240, 96);
this.txtDataTx.TabIndex = 0;
this.txtDataTx.Text = "";
//
// groupBox3
//
this.groupBox3.Location = new System.Drawing.Point(0, 240);
this.groupBox3.Name = "groupBox3";
this.groupBox3.Size = new System.Drawing.Size(288, 112);
this.groupBox3.TabIndex = 3;
this.groupBox3.TabStop = false;
this.groupBox3.Text = "Data Received";
//
// Form1
//
this.AutoScaleBaseSize = new System.Drawing.Size(5, 13);
this.ClientSize = new System.Drawing.Size(296, 349);
this.Controls.AddRange(new System.Windows.Forms.Control[] {
this.groupBox2,
this.txtDataRx,
this.groupBox1,
this.groupBox3});
this.Name = "Form1";
this.Text = "Socket Server in C#";
this.groupBox1.ResumeLayout(false);
this.groupBox2.ResumeLayout(false);
this.ResumeLayout(false);
}
#endregion
/// <summary>
/// The main entry point for the application.
/// </summary>
[STAThread]
static void Main()
{
Application.Run(new Form1());
}
private void cmdListen_Click(object sender, System.EventArgs e)
{
try
{
//create the listening socket...
m_socListener = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
IPEndPoint ipLocal = new IPEndPoint ( IPAddress.Any ,8221);
//bind to local IP Address...
m_socListener.Bind( ipLocal );
//start listening...
m_socListener.Listen (4);
// create the call back for any client connections...
m_socListener.BeginAccept(new AsyncCallback ( OnClientConnect ),null);
cmdListen.Enabled = false;
}
catch(SocketException se)
{
MessageBox.Show ( se.Message );
}
}
public void OnClientConnect(IAsyncResult asyn)
{
try
{
m_socWorker = m_socListener.EndAccept (asyn);
WaitForData(m_socWorker);
}
catch(ObjectDisposedException)
{
System.Diagnostics.Debugger.Log(0,"1","\n OnClientConnection: Socket has been closed\n");
}
catch(SocketException se)
{
MessageBox.Show ( se.Message );
}
}
public class CSocketPacket
{
public System.Net.Sockets.Socket thisSocket;
public byte[] dataBuffer = new byte[1];
}
public void WaitForData(System.Net.Sockets.Socket soc)
{
try
{
if ( pfnWorkerCallBack == null )
{
pfnWorkerCallBack = new AsyncCallback (OnDataReceived);
}
CSocketPacket theSocPkt = new CSocketPacket ();
theSocPkt.thisSocket = soc;
// now start to listen for any data...
soc .BeginReceive (theSocPkt.dataBuffer ,0,theSocPkt.dataBuffer.Length ,SocketFlags.None,pfnWorkerCallBack,theSocPkt);
}
catch(SocketException se)
{
MessageBox.Show (se.Message );
}
}
public void OnDataReceived(IAsyncResult asyn)
{
try
{
CSocketPacket theSockId = (CSocketPacket)asyn.AsyncState ;
//end receive...
int iRx = 0 ;
iRx = theSockId.thisSocket.EndReceive (asyn);
char[] chars = new char[iRx + 1];
System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();
int charLen = d.GetChars(theSockId.dataBuffer, 0, iRx, chars, 0);
System.String szData = new System.String(chars);
txtDataRx.Text = txtDataRx.Text + szData;
WaitForData(m_socWorker );
}
catch (ObjectDisposedException )
{
System.Diagnostics.Debugger.Log(0,"1","\nOnDataReceived: Socket has been closed\n");
}
catch(SocketException se)
{
MessageBox.Show (se.Message );
}
}
private void button1_Click(object sender, System.EventArgs e)
{
try
{
Object objData = txtDataTx.Text;
byte[] byData = System.Text.Encoding.ASCII.GetBytes(objData.ToString ());
m_socWorker.Send (byData);
}
catch(SocketException se)
{
MessageBox.Show (se.Message );
}
}
}
}
Håber i kan hjælpe
Indlæg senest redigeret d. 02.01.2010 00:13 af Bruger #10613