例子是学习编程的法宝你在学习java Socket 吗?看看下面的这个例子吧!
实现Client端功能的ClientAppjava原文件
import *;
import javaio*;
import javalang*;
public class ClientApp
{
public static void main(String args[])
{
try
{
//创建通讯并且和主机Rock连接
Socket cSocket=new Socket();
//打开这个Socket的输入/输出流
OutputStream os=cSocketgetOutputStream();
DataInputStream is=new DataInputStream(cSocketgetInputStream());
int c;
boolean flag=true;
String responseline;
while(flag)
{
//从标准输入输出接受字符并且写如系统
while((c=Systeminread())!=)
{
oswrite((byte)c);
if(c==\n)
{
osflush();
//将程序阻塞直到回答信息被收到后将他们在标准输出上显示出来
responseline=isreadLine();
Systemoutprintln(Message is:+responseline);
}
}
}
osclose();
isclose();
cSocketclose();
}
catch(Exception e)
{
Systemoutprintln(Exception :+ egetMessage());
}
}
}
实现Server端功能的ServerAppjava原文件
import *;
import javaio*;
public class ServerApp
{
public static void main(String args[])
{
try
{
boolean flag=true;
Socket clientSocket=null;
String inputLine;
int c;
ServerSocket sSocket=new ServerSocket();
Systemoutprintln(Server listen on:+sSocketgetLocalPort());
while(flag)
{
clientSocket=sSocketaccept();
DataInputStream is= new DataInputStream(new BufferedInputStream(clientSocketgetInputStream()));
OutputStream os=clientSocketgetOutputStream();
while((inputLine=isreadLine())!=null)
{
//当客户端输入stop的时候服务器程序运行终止!
if(inputLineequals(stop))
{
flag=false;
break;
}
else
{
Systemoutprintln(inputLine);
while((c=Systeminread())!=)
{
oswrite((byte)c);
if(c==\n)
{
osflush(); //将信息发送到客户端
break;
}
}
}
}
isclose();
osclose();
clientSocketclose();
}
sSocketclose();
}
catch(Exception e)
{
Systemoutprintln(Exception :+ egetMessage());
}
}
}