用Socket实现client和Server的问题
我们老师要我们写一个用Socket实现client和Server的作业
现在上网找了点代码
能实现客户端向服务器端发送消息
但只能是一个。。
我对线程认识太少了
希望各位帮我改改
实现服务端一直监听 就是说客户端随时发信息服务器都能应答(以下程序只能服务端返回一次信息)
客户端:
- Java code
package test.bwl; import java.io.BufferedReader;import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader;import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class SocketClient { public static void main(String[] args) { Socket socket = null; DataOutputStream doc; DataInputStream in ; try { socket = new Socket("127.0.0.1", 1234); OutputStream netOut = socket.getOutputStream(); doc = new DataOutputStream(netOut); in = new DataInputStream(socket.getInputStream()); BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); int flag=1; doc = new DataOutputStream(netOut); in = new DataInputStream(socket.getInputStream()); while(flag==1) { System.out.print("请输入要发送的内容(输入exit退出)\n"); String what=br.readLine(); if("exit".equals(what)) break; doc.writeUTF(what); String res = in.readUTF(); System.out.println("客户端--->"+res); } doc.close(); in.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { if (socket != null) { try { socket.close(); System.out.println("关闭成功"); } catch (IOException e) { } } } } }
服务器端:
- Java code
package test.bwl; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; public class SocketManager { /** * @param args * @throws IOException */ public static void main(String[] args) { SocketManager manager = new SocketManager(); System.out.println("启动监听....."); manager.doListen(); } public void doListen() { ServerSocket server; try { server = new ServerSocket(1234); while (true) { Socket client = server.accept(); new Thread(new SSocket(client)).start(); } } catch (IOException e) { e.printStackTrace(); } } //服务器进程 class SSocket implements Runnable { Socket client; public SSocket(Socket client) { this.client = client; } public void run() { DataInputStream input; DataOutputStream output; try { input = new DataInputStream(client.getInputStream()); output = new DataOutputStream(client.getOutputStream()); String listMsg = input.readUTF(); output.writeUTF("服务器接收-->发回: " + listMsg ); System.out.println("接收: " + listMsg); } catch (Exception e) { e.printStackTrace(); } } } }
[解决办法]
在run方法里面写一个死循环不就行了嘛。
[解决办法]
http://blog.csdn.net/thegodofwar/archive/2010/08/12/5808206.aspx
看看这个,我写的