- 相关推荐
Javasocket应用实例
引导语：运用Java，我们可以编出很多有趣的小程序，以下是百分网小编分享给大家的Javasocket应用实例，希望大家喜欢!
用于本机上的客户端与服务器对话的小程序：
客户端：
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class Client extends Thread
{
public void Write() throws Exception
{
Socket s=new Socket("127.0.0.1",12345);
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
String message="客户端说:";
while(!(message.equals("")))
{
message=br.readLine();
System.out.println("客户端说:"+message);
bw.write(message+"\n");
bw.flush();
}
bw.close();
s.close();
}
public void run()
{
Socket m=null;
BufferedReader dr=null;
try
{
m=new Socket("127.0.0.1",12345);
dr=new BufferedReader(new InputStreamReader(m.getInputStream()));
String msg="服务器说:";
while(!(msg.equals("")))
{
msg=dr.readLine();
System.out.println("服务器说:"+msg);
}
}
catch(Exception e){e.printStackTrace();}
finally
{
try
{
dr.close();
m.close();
}
catch(Exception e){e.printStackTrace();}
}
}
public static void main(String args[])throws Exception
{
Client c=new Client();
c.start();
c.Write();
}
}
服务器：
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server extends Thread
{
private ServerSocket ss=null;
public Server ()throws Exception
{
ss=new ServerSocket(12345);
}
public void Write()throws Exception
{
Socket s=ss.accept();
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
String message="服务器说:";
while(!(message.equals("")))
{
message=br.readLine();
System.out.println("服务器说:"+message);
bw.write(message+"\n");
bw.flush();
}
//bw.close();
s.close();
}
public void run()
{
Socket m=null;
BufferedReader dr=null;
try
{
m=ss.accept();
dr=new BufferedReader(new InputStreamReader(m.getInputStream()));
String msg="客户端说:";
while(!(msg.equals("")))
{
msg=dr.readLine();
System.out.println("客户端:"+msg);
}
}
catch(Exception e){e.printStackTrace();}
finally
{
try
{
dr.close();
m.close();
}
catch(Exception e){e.printStackTrace();}
}
}
public static void main(String args[])throws Exception
{
Server s=new Server();
s.start();
s.Write();
}
}
用于本地群聊的小程序：
客户端：
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class Friendclient extends Thread
{
public void Writer() throws Exception
{
Socket s=new Socket("127.0.0.1",54321);
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
String message="本客户端说:";
while(!(message.equals("goodbye")))
{
message=br.readLine();
System.out.println("客户端说:"+message);
bw.write(message+"\n");
bw.flush();
}
bw.close();s.close();
}
public void run()
{
BufferedReader bq=null;
Socket st=null;
try
{
st=new Socket("127.0.0.1",54321);
bq=new BufferedReader(new InputStreamReader(st.getInputStream()));
String msg="其他客户端说:";
while(!(msg.equals("")))
{
msg=bq.readLine();
System.out.println("其他客户端说:"+msg);
}
}
catch(Exception e){e.printStackTrace();}
finally
{
try
{
bq.close();st.close();
}
catch(Exception e){e.printStackTrace();}
}
}
public static void main(String args[])throws Exception
{
Friendclient ft=new Friendclient();
ft.start();
ft.Writer();
}
}
服务器端：
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
public class Allserver
{
private ServerSocket ss=null;
private static ArrayList al=new ArrayList();
public Allserver() throws Exception
{
ss=new ServerSocket(54321);
while(true)
{
Socket s=ss.accept();
al.add(s);
new Mtherd(s).start();
}
}
private class Mtherd extends Thread
{
private Socket sd=null;
private BufferedReader br=null;
//private BufferedWriter bw=null;
public Mtherd(Socket sd)throws Exception
{
this.sd=sd;
br=new BufferedReader(new InputStreamReader(sd.getInputStream()));
//bw=new BufferedWriter(new OutputStreamWriter(sd.getOutputStream()));
}
public void run()
{
try
{
String gh="...................";
while(true)
{
gh=br.readLine();
setAll(gh);
}
}
catch(Exception e){e.printStackTrace();}
}
public void setAll(String x)throws Exception
{
Socket ss=null;
BufferedWriter bv=null;
for(int i=0;i
{
ss=(Socket)al.get(i);
bv=new BufferedWriter(new OutputStreamWriter(ss.getOutputStream()));
bv.write(x+"\n");
bv.flush();
}
}
}
public static void main(String args[])throws Exception
{
new Allserver();
}
}
【Javasocket应用实例】相关文章：
firework“外发光”特效的应用实例08-19
javasocket服务端技巧10-22
项目管理案例：在通信工程中的应用实例11-01
高一数学《函数模型的应用实例》教案设计10-14
英语书面表达提纲类应用文写作分析实例09-18
操作系统故障恢复控制台应用实例详解10-22
php画图实例07-16
AXURE交互实例介绍10-15
地道美式短语及实例07-22