这是客户端的代码(放到VISTA下运行): using System; using System.Collections.Generic; using System.Text; using System.Net.Sockets; using System.IO; using System.Threading;namespace Test { class Program { public int m_iMinLineInterval = 60; public TradeTimeVO[] m_timeRange = null; static void Main(string[] args) { Program p = new Program(); TcpClient tcpSend = new TcpClient(); TcpClient tcpRes = new TcpClient(); tcpSend.Connect("ip地址", 端口); p.Res(tcpSend); } private void Res(TcpClient tcpRes) { Console.WriteLine("开始接收..."); NetworkStream res = tcpRes.GetStream(); BinaryReader br = new BinaryReader(new BufferedStream(res)); while (true) { byte b = br.ReadByte(); switch (b) { case 20: Console.WriteLine("收到"); break; default: break; } } Console.ReadLine(); } } }
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class HQService
{
public static void main(String[] args)
{
System.out.println("start...");
test(256); //循环256次
}
public static void test(int n)
{
Socket socket1=null;
try
{
ServerSocket server = new ServerSocket(8002);
System.out.println("server open...");
socket1 = server.accept();
System.out.println("client lianjie..");
DataOutputStream output = new DataOutputStream(new BufferedOutputStream(socket1.getOutputStream()));
ByteArrayOutputStream array = new ByteArrayOutputStream();
DataOutputStream output1 = new DataOutputStream(array); for(int i=0;i<n;i++)
{
output1.writeByte(20);
}
output1.flush();
array.flush();
output.write(array.toByteArray());
output.flush();
output1.close();
array.close();
output.close();
}
catch (IOException e)
{
try {
socket1.close();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
e.printStackTrace();
}
catch (Exception e1)
{
e1.printStackTrace() ;
}
}
}
using System;
using System.Collections.Generic;
using System.Text;
using System.Net.Sockets;
using System.IO;
using System.Threading;namespace Test
{
class Program
{
public int m_iMinLineInterval = 60;
public TradeTimeVO[] m_timeRange = null; static void Main(string[] args)
{
Program p = new Program();
TcpClient tcpSend = new TcpClient();
TcpClient tcpRes = new TcpClient();
tcpSend.Connect("ip地址", 端口); p.Res(tcpSend);
} private void Res(TcpClient tcpRes)
{
Console.WriteLine("开始接收...");
NetworkStream res = tcpRes.GetStream();
BinaryReader br = new BinaryReader(new BufferedStream(res));
while (true)
{
byte b = br.ReadByte();
switch (b)
{
case 20:
Console.WriteLine("收到");
break;
default:
break;
}
}
Console.ReadLine();
} }
}