您的位置:首页 > 编程语言 > C#

C# Asterisk Manager Interface 实例

2011-12-31 18:09 197 查看
using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Net;

using System.IO;

using System.Text;

using System.Windows.Forms;

using System.Net.Sockets;

using System.Threading;

namespace Manager_API

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

// list = new TcpListener(5038);

Page_Loaded1();

}

private void button1_Click(object sender, EventArgs e)

{

}

private void Form1_Load(object sender, EventArgs e)

{

}

private Socket _socket; // 客户端 Socket

// Socket 异步操作对象

private SocketAsyncEventArgs _sendEventArgs;

private SocketAsyncEventArgs _conEventArgs;

private SocketAsyncEventArgs _receiveEventArgs;

void Page_Loaded1()

{

// 实例化 Socket

_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

// 实例化 SocketAsyncEventArgs ,用于对 Socket 做异步操作,很方便

this._conEventArgs = new SocketAsyncEventArgs();

// 服务器的 EndPoint

this._conEventArgs.RemoteEndPoint = new DnsEndPoint("192.168.9.95", 5038);

// 异步操作完成后执行的事件

this._conEventArgs.Completed += new EventHandler<SocketAsyncEventArgs>(OnSocketConnectCompleted);

// 异步连接服务端

_socket.ConnectAsync(this._conEventArgs);

}

private void OnSocketConnectCompleted(object sender, SocketAsyncEventArgs e)

{

// 设置数据缓冲区

byte[] response = new byte[1024];

_sendEventArgs = new SocketAsyncEventArgs();

_receiveEventArgs = new SocketAsyncEventArgs();

_receiveEventArgs.SetBuffer(response, 0, response.Length);

// 修改 SocketAsyncEventArgs 对象的异步操作完成后需要执行的事件

//e.Completed -= new EventHandler<SocketAsyncEventArgs>(OnSocketConnectCompleted);

_receiveEventArgs.Completed += new EventHandler<SocketAsyncEventArgs>(OnSocketReceiveCompleted);

_sendEventArgs.Completed += new EventHandler<SocketAsyncEventArgs>(OnSocketSendCompleted);

_socket.ReceiveAsync(_receiveEventArgs);

if (!_socket.Connected)

{

}

else

{

//byte[] by = Encoding.ASCII.GetBytes("Action: Login\r\nUsername: mark\r\nSecret: mysecret\r\nActionID: 1\r\n\r\n");

//SendData(by);

byte[] by = Encoding.ASCII.GetBytes("Action: Login\r\nUsername: wangw\r\nSecret: 123456\r\n\r\n");

SendData(by);

}

}

private void SendData(byte[] a)

{

if (_socket.Connected)

{

_sendEventArgs = new SocketAsyncEventArgs();

_sendEventArgs.RemoteEndPoint = new DnsEndPoint("192.168.9.95", 5038);

// 设置需要发送的数据的缓冲区

_sendEventArgs.BufferList =

new List<ArraySegment<byte>>()

{

new ArraySegment<byte>(a)

};

// 异步地向服务端 Socket 发送消息

_socket.SendAsync(_sendEventArgs);

}

else

{

}

}

private void OnSocketSendCompleted(object sender, SocketAsyncEventArgs e)

{

}

private void OnSocketReceiveCompleted(object sender, SocketAsyncEventArgs e)

{

byte[] response = new byte[1024];

byte[] by1 = e.Buffer;

string a = Encoding.ASCII.GetString(by1);

e.SetBuffer(response, 0, response.Length);

_socket.ReceiveAsync(e);

}

}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: