//Agregar
using System.IO;
using System.Net;
using System.Net.Sockets;
namespace ClienteTCP
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
TcpClient cliente = new TcpClient();
byte[] bufferTx;
private void btnCOnectar_Click(object sender, EventArgs e)
{
int puerto = Convert.ToInt32(txtPuerto.Text);
IPAddress direccionIp = IPAddress.Parse(txtDireccion.Text);
IPEndPoint puntoRemoto = new IPEndPoint(direccionIp, puerto);
cliente.Connect(puntoRemoto);
NetworkStream mensaje = cliente.GetStream();
bufferTx = Encoding.ASCII.GetBytes("$Conectar");
if (mensaje != null)
{
mensaje.Write(bufferTx, 0, bufferTx.Length);
btnCOnectar.Enabled = false;
}
}
private void btnEnviar_Click(object sender, EventArgs e)
{
if (cliente.Connected)
{
NetworkStream mensaje = cliente.GetStream();
bufferTx = Encoding.ASCII.GetBytes(txtEnviar.Text);
mensaje.Write(bufferTx, 0, bufferTx.Length);
//cliente.Close();
}
}
}
}
=======================================================================
/*ServidorTCP
//Agregar
using System.IO;
using System.Net;
using System.Net.Sockets;
namespace ServidorTCP
{
class Program
{
private const int puertoEscucha = 12345;
static void Main(string[] args)
{
bool terminado = false;
int cuenta;
byte[] bufferRx = new byte[1024];
string datosRx = "";
TcpClient manejoCliente;
IPAddress direccionIp = IPAddress.Parse("127.0.0.1");
IPEndPoint puntoLocal = new IPEndPoint(direccionIp,puertoEscucha);
TcpListener servidor = new TcpListener(puntoLocal);
Console.WriteLine("El servidor esta escuchando...");
servidor.Start();
while(!terminado)
{
manejoCliente = servidor.AcceptTcpClient();
NetworkStream flujo = manejoCliente.GetStream();
do
{
bufferRx = new byte[1024];
cuenta = flujo.Read(bufferRx, 0, bufferRx.Length);
if (cuenta > 0)
{
datosRx = Encoding.ASCII.GetString(bufferRx);
Console.WriteLine("Mensaje recibido: "+datosRx);
}
} while (cuenta > 0);
}
}
}
}
No hay comentarios:
Publicar un comentario