public partial class Form1 : Form
{
private WasapiLoopbackCapture mic;//音频输入
protected RDPSession _rdpSession = null;
public Form1()
{
InitializeComponent();
}
static Thread receiveThread;
private void Form1_Load(object sender, EventArgs e)
{
SocketReceiver socketReceiver = new SocketReceiver();
socketReceiver.Send();
}
public string GetInvitationString()
{
_rdpSession = new RDPSession(); // 新建RDP Session
_rdpSession.OnAttendeeConnected += new _IRDPSessionEvents_OnAttendeeConnectedEventHandler(OnAttendeeConnected);
_rdpSession.OnAttendeeDisconnected += new _IRDPSessionEvents_OnAttendeeDisconnectedEventHandler(OnAttendeeDisconnected);
_rdpSession.OnControlLevelChangeRequest += new _IRDPSessionEvents_OnControlLevelChangeRequestEventHandler(OnControlLevelChangeRequest);//用户的级别
//_rdpSession.SetDesktopSharedRect(0, 0, 991, 699); // 设置共享区域，如果不设置默认为整个屏幕，当然如果有多个屏幕，还是设置下主屏幕，否则，区域会很大
_rdpSession.Open();
IRDPSRAPIInvitation pInvitation = _rdpSession.Invitations.CreateInvitation("WinPresenter", "PresentationGroup", "", 5);//获取连接的字符串
string invitationString = pInvitation.ConnectionString;
return invitationString;
}
/// <summary>
/// 开始
/// </summary>
private void button1_Click(object sender, EventArgs e)
{
textBox1.Text = GetInvitationString();
SoundSender sender1 = new SoundSender("172.21.47.86");
sender1.StartSending();
}
private void OnAttendeeConnected(object pObjAttendee)
{
IRDPSRAPIAttendee pAttendee = pObjAttendee as IRDPSRAPIAttendee;
pAttendee.ControlLevel = CTRL_LEVEL.CTRL_LEVEL_VIEW;
}
private void button2_Click(object sender, EventArgs e)
{
try
{
_rdpSession.Close();
Marshal.ReleaseComObject(_rdpSession);
_rdpSession = null;
}
catch (Exception ex)
{
}
}
private void button3_Click(object sender, EventArgs e)
{
new Form3().Show();
}
private void button5_Click(object sender, EventArgs e)
{
if (string.IsNullOrEmpty(textBox2.Text.Trim()))
{
MessageBox.Show("IP地址不能为空");
return;
}
SocketSend send = new SocketSend();
send.Send(textBox2.Text.Trim());
button5.Enabled = false;
}
void OnAttendeeDisconnected(object pDisconnectInfo)
{
IRDPSRAPIAttendeeDisconnectInfo pDiscInfo = pDisconnectInfo as IRDPSRAPIAttendeeDisconnectInfo;
}
private void button4_Click(object sender, EventArgs e)
{
var txtMsg = this.button4.Text.Trim();
if (txtMsg == "获取声音")
{
SoundReceiver receiver = new SoundReceiver();
receiver.StartReceiving();
this.button4.Text = "关闭声音";
}
else
{
SoundReceiver receiver = new SoundReceiver();
receiver.StopReceiving();
this.button4.Text = "获取声音";
}
}
/// <summary>
/// 更改控制级别
/// </summary>
/// <param name="pObjAttendee"></param>
/// <param name="RequestedLevel"></param>
void OnControlLevelChangeRequest(object pObjAttendee, CTRL_LEVEL RequestedLevel)
{
IRDPSRAPIAttendee pAttendee = pObjAttendee as IRDPSRAPIAttendee;
pAttendee.ControlLevel = RequestedLevel;
}
}
public partial class Form2 : Form
{
public Form2()
{
InitializeComponent();
}
public string connctionString = "";
private void axRDPViewer1_Enter(object sender, EventArgs e)
{
}
private void Form2_Load(object sender, EventArgs e)
{
}
public void SetConnectionString(string conn)
{
connctionString = conn;
}
public void button1_Click(object sender, EventArgs e)
{
//new Form3().Show();
Connect(connctionString);
}
/// <summary>
/// 开始共享仪器客户端界面
/// </summary>
public void Connect(string connctionString)
{
string ConnectionString = connctionString;
if (ConnectionString != null)
{
try
{
axRDPViewer1.Connect(ConnectionString, "Viewer1", "");
}
catch (Exception ex)
{
}
}
}
/// <summary>
/// 结束控制
/// </summary>
public void stopcontrol()
{
axRDPViewer1.RequestControl(RDPCOMAPILib.CTRL_LEVEL.CTRL_LEVEL_MAX);
}
/// <summary>
/// 开始控制
/// </summary>
public void control()
{
axRDPViewer1.RequestControl(RDPCOMAPILib.CTRL_LEVEL.CTRL_LEVEL_MAX);
}
/// <summary>
/// 停止共享仪器客户端界面
/// </summary>
public void DisConnect()
{
axRDPViewer1.Disconnect();
}
private void button2_Click(object sender, EventArgs e)
{
control();
}
}
public partial class Form3 : Form
{
public Form3()
{
InitializeComponent();
}
private void button1_Click(object sender, EventArgs e)
{
var form= new Form2();
form.Show();
form.SetConnectionString(textBox1.Text);
form.button1_Click(sender,e);
this.Hide();
}
}
public class SocketReceiver
{
// 本地IP地址和端口
string ipAddress = "0.0.0.0";
int port = 12344;
Thread thread;
Socket receiverSocket;
public string Send()
{
string receivedMessage = "";
thread = new Thread(ReceiveData);
thread.Start();
return receivedMessage;
}
public void ReceiveData()
{
// 创建接收端Socket
receiverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
try
{
// 创建本地终结点
IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Parse(ipAddress), port);
// 将Socket绑定到本地终结点
receiverSocket.Bind(localEndPoint);
while (true)
{
// 接收数据
byte[] buffer = new byte[1024];
EndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0);
int bytesRead = receiverSocket.ReceiveFrom(buffer, ref remoteEndPoint);
// 将接收到的数据转换为字符串
string receivedMessage = Encoding.UTF8.GetString(buffer, 0, bytesRead);
SoundSender sender1 = new SoundSender(receivedMessage);
sender1.StopSending();
sender1.StartSending();
}
}
catch (Exception ex)
{
// 关闭接收端Socket
receiverSocket.Close();
}
finally
{
}
}
}
public class SocketSend
{
// 目标IP地址和端口
string ipAddress = "127.0.0.1";
int port = 12344;
public void Send(string message)
{
//message = "Hello, Receiver!";
// 创建发送端Socket
Socket senderSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
try
{
byte[] data = Encoding.UTF8.GetBytes(message);
// 创建目标终结点
IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ipAddress), port);
// 发送数据到目标终结点
senderSocket.SendTo(data, endPoint);
}
catch (Exception ex)
{
}
finally
{
// 关闭发送端Socket
senderSocket.Close();
}
}
}
public class SoundReceiver
{
public static UdpClient udpClient;
public static IPEndPoint endPoint;
public static WaveOut waveOut;
public static BufferedWaveProvider waveProvider;
public SoundReceiver()
{
}
public void StartReceiving()
{
udpClient = new UdpClient(12345); // 接收端监听的端口号
endPoint = new IPEndPoint(IPAddress.Any, 0);
waveOut = new WaveOut();
waveProvider = new BufferedWaveProvider(new WaveFormat(44100, 1));
waveOut.Init(waveProvider);
udpClient.BeginReceive(ReceiveCallback, null);
waveOut.Play();
}
public void StopReceiving()
{
waveOut.Stop();
udpClient.Client.Shutdown(SocketShutdown.Both);
udpClient.Close();
}
private void ReceiveCallback(IAsyncResult ar)
{
try
{
byte[] receivedData = udpClient.EndReceive(ar, ref endPoint);
waveProvider.AddSamples(receivedData, 0, receivedData.Length);
udpClient.BeginReceive(ReceiveCallback, null);
}
catch (Exception)
{
}
}
}
public class SoundSender
{
private WasapiLoopbackCapture waveIn;
private UdpClient udpClient;
private IPEndPoint endPoint;
public SoundSender(string ipAddress)
{
waveIn = new WasapiLoopbackCapture();
waveIn.WaveFormat = new WaveFormat(44100, 1);
udpClient = new UdpClient();
endPoint = new IPEndPoint(IPAddress.Parse(ipAddress), 12345); // 替换为接收端的IP地址
waveIn.DataAvailable += WaveIn_DataAvailable;
}
public void StartSending()
{
waveIn.StartRecording();
}
public void StopSending()
{
waveIn.StopRecording();
}
private void WaveIn_DataAvailable(object sender, WaveInEventArgs e)
{
udpClient.Send(e.Buffer, e.BytesRecorded, endPoint);
}
}
以上代码仅供参考，是测试代码
标签：UDP,RDP,void,object,private,new,public,电脑屏幕,string From： https://www.cnblogs.com/liao-long/p/17600593.html