TCP/ip Socket 短连接 Demo(新手请进~~~~欢迎拍砖)
要搞心跳包 实在能力有限) 不多说 贴图。帖demo
----IP Service ------
----IP Client------
----IP Service Major code------
private void BeginListen()
{
serverIP = IPAddress.Parse(tbxIP.Text);
serverFullAddr = new IPEndPoint(serverIP, int.Parse(tbxPort.Text));//设置IP,端口
sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//指定本地主机地址和端口号
sock.Bind(serverFullAddr);
lbxMessage.Invoke(new SetTextCallback(SetText), "启动成功 时间:"+DateTime.Now, 1);
byte[] message = new byte[1024];
string mess = "";
while (true)
{
try
{
sock.Listen(5);//设置监听频率
Socket newSocket = sock.Accept();//阻塞方式
int bytes= newSocket.Receive(message);//接收数据
mess = Encoding.Default.GetString(message, 0, bytes);//对接收字节编码(S与C 两端编码格式必须一致不然中文乱码)(当接收的字节大于1024的时候 这应该是循环接收,测试就没有那样写了)
//do
//{
// bytes = newSocket.Receive(message, message.Length, 0);
// mess = mess + Encoding.ASCII.GetString(message, 0, bytes);
//}
// while (bytes > 0);
lbxMessage.Invoke(new SetTextCallback(SetText),mess,1);//子线程操作主线程UI控件
mess = "已接收数据: " + mess + " 当前时间为:" + DateTime.Now;
newSocket.Send(Encoding.Default.GetBytes(mess));//想客户端发送数据
}
catch (SocketException se)
{
lbxMessage.Invoke(new SetTextCallback(SetText), mess, 1);
}
}
}
//发送消息
private void btnSend_Click(object sender, EventArgs e)
{
serverFullAddr = new IPEndPoint(serverIP, int.Parse(tbxPort.Text));//设置IP,端口
sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//指定本地主机地址和端口号
sock.Connect(serverFullAddr);
byte[] byteSend = System.Text.Encoding.Default.GetBytes(this.tbxMessage.Text);
byte[] message = new byte[1024];
string mess = "";
int bytes = 0;
try
{
//发送数据
sock.Send(byteSend);
bytes = sock.Receive(message);//接收数据
mess = mess + Encoding.Default.GetString(message,0,bytes);//编码(当接收的字节大于1024的时候 这应该是循环接收,测试就没有那样写了)
//do
//{
// bytes = newSocket.Receive(message, message.Length, 0);
// mess = mess + Encoding.ASCII.GetString(message, 0, bytes);
//}
// while (bytes > 0);
tbxMessage.Text = mess;
}
catch (Exception ex)
{
lblError.Text = "出现错误,请联系管理员";
}
sock.Close();
}
static void Main(string[] args)
{
TcpListener listener = null;
int portNum = 9001;
byte[] bytes = new byte[1024];
try
{
Console.WriteLine("开启服务器端窗口。。。。");
Console.WriteLine("请等待连接...");
bool done = false;
listener = new TcpListener(IPAddress.Parse("127.0.0.1"), portNum);
listener.Start();//开始监听
while (!done)
{
TcpClient client = listener.AcceptTcpClient();
Console.WriteLine("连接成功........");
NetworkStream ns = client.GetStream();
int num=ns.Read(bytes,0,bytes.Length);//读C端发送的数据
Console.WriteLine(Encoding.ASCII.GetString(bytes, 0, num));//编码
byte[] byteTime = Encoding.ASCII.GetBytes(DateTime.Now.ToString());
try
{
ns.Write(byteTime, 0, byteTime.Length);//像C端发送数据
ns.Close();
client.Close();
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}
listener.Stop();
}
catch (Exception ee)
{
Console.Write("错误提示:" + ee.Message);
}
finally
{
// Stop listening for new clients.
listener.Stop();
}
Console.WriteLine("\nHit enter to continue...");
Console.Read();
}
[解决办法]
每天回帖即可获得10分可用分!
[解决办法]
[解决办法]
去下来看看,,
[解决办法]
[解决办法]
qqq
[解决办法]
支持LZ。。闲的蛋疼时是要找点事做做。。
[解决办法]
努力赚分
[解决办法]
支持分享 谢谢楼主 !!
[解决办法]
mark
[解决办法]
支持分享 谢谢楼主 !!
[解决办法]
支持分享
[解决办法]
简单的例子,
[解决办法]
支持下LZ,多学点东西总是好的
[解决办法]
不错~~~~~~~~··支持一下
[解决办法]
好东西,不错!
[解决办法]
不错 闲的时候多做点这类事
[解决办法]
发得太及时了,我正在做短信接口需要用到,不过有个问题不是很明白:发送4个字节的消息头、发送4个字节对应长度的请求消息体报文 是什么意思?谢谢
[解决办法]
哈哈,我今天刚好写了个!!
[解决办法]
飘过学习学习
[解决办法]
回帖拿分~
[解决办法]
谢了 最近有这方面需求 正要看呢
[解决办法]
谢谢分享
[解决办法]
[解决办法]
刚整了个异步的。。 。
[解决办法]
推荐使用.net3.5推出的SocketAsyncEventArgs进一步提升性能
[解决办法]
回帖能有分吗?
[解决办法]
分。。。。。
[解决办法]
zhichi up
[解决办法]
[解决办法]
做个记号.............