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);
}
}
}
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);
}
}
}
相关文章推荐
- C# Asterisk Manager Interface 实例
- Asterisk Manager Interface(AMI)
- c# interface virtual ,abstract ,多态实例
- c# interface 的理解(工厂模式)简单实例
- c# interface 的理解(工厂模式)简单实例
- AMI 工具(Asterisk Manager Interface)
- C#接口interface用法实例
- Asterisk Manager Interface(AMI)
- AMI Asterisk Manager Interface
- Asterisk Manager Interface(AMI)
- C# 事件模型(基于委托)实例参考
- 自定义数据类型,操作符重载实例[C#]
- c#存储图片到数据库读数据库显示图片实例
- C#使用webbrowser的常见用法实例
- C#操作Access通用类实例
- C#反射实例讲解
- 谈谈对C#委托的理解,附代码实例
- 适配器模式实例(C#)
- c# ThreadPool 应用实例
- C#命令行参数解析类以及使用实例