实现client端功能的clientapp.java原文件：

import java.net.*;
import java.io.*;
import java.lang.*;

public class clientapp
{
public static void main(string args[])
{
try
{
//创建通讯并且和主机rock连接
socket csocket=new socket("192.168.100.188",8018);
//打开这个socket的输入/输出流
outputstream os=csocket.getoutputstream();
datainputstream is=new datainputstream(csocket.getinputstream());

int c;
boolean flag=true;

string responseline;

while(flag)
{
//从标准输入输出接受字符并且写如系统
while((c=system.in.read())!=-1)
{
os.write((byte)c);
if(c=='/n')
{
os.flush();
//将程序阻塞，直到回答信息被收到后将他们在标准输出上显示出来
responseline=is.readline();
system.out.println("message is:"+responseline);
}
}
}
os.close();
is.close();
csocket.close();

}
catch(exception e)
{
system.out.println("exception :"+ e.getmessage());
}
}
}


实现server端功能的serverapp.java原文件：

import java.net.*;
import java.io.*;

public class serverapp
{
public static void main(string args[])
{
try
{
boolean flag=true;
socket clientsocket=null;
string inputline;
int c;

serversocket ssocket=new serversocket(8018);
system.out.println("server listen on:"+ssocket.getlocalport());

while(flag)
{
clientsocket=ssocket.accept();
datainputstream is= new datainputstream(new bufferedinputstream(clientsocket.getinputstream()));
outputstream os=clientsocket.getoutputstream();

while((inputline=is.readline())!=null)
{
//当客户端输入stop的时候服务器程序运行终止！
if(inputline.equals("stop"))
{
flag=false;
break;
}
else
{
system.out.println(inputline);

while((c=system.in.read())!=-1)
{
os.write((byte)c);
if(c=='/n')
{
os.flush(); //将信息发送到客户端
break;
}
}
}


}
is.close();
os.close();
clientsocket.close();

}
ssocket.close();
}
catch(exception e)
{
system.out.println("exception :"+ e.getmessage());
}
}
}