问题描述
这是服务端代码package com.hj.demo.socket;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class Server {public Server() throws IOException {ServerSocket ss = new ServerSocket(7777);while (true) {Socket sk = ss.accept();ClientThread ct = new ClientThread(sk);ct.start();System.out.println("服务端已启动...");}}// 多线程客户端class ClientThread extends Thread {private Socket clientSocket = null;public ClientThread(Socket clientSocket) {this.clientSocket = clientSocket;}DataInputStream dis = new DataInputStream(null);@SuppressWarnings("deprecation")@Overridepublic void run() {// TODO Auto-generated method stubString hostName = clientSocket.getInetAddress().toString();System.out.println("hostName:>" + hostName+"已连接");String msg = null;try {dis = new DataInputStream(clientSocket.getInputStream());while (true) {msg = dis.readUTF();System.out.println(hostName + "发来的消息>: " + msg);if(null==dis.readLine()||"".equals(dis.readLine())){break;}}if(!"".equals(msg)&&msg.length()!=0){DataOutputStream dos = new DataOutputStream(clientSocket.getOutputStream());String rep = "我是返回给由"+hostName+"发来["+msg+"]的消息";System.out.println(rep);dos.writeUTF(rep);dos.close();}} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}super.run();}}public static void main(String[] args) throws IOException {new Server();}}这是客户端的代码package com.hj.demo.socket;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;public class Client {public static void main(String[] args) throws UnknownHostException,IOException, InterruptedException {Socket sk = new Socket("127.0.0.1", 7777);DataOutputStream dos = new DataOutputStream(sk.getOutputStream());DataInputStream dis = new DataInputStream(sk.getInputStream());dos.writeUTF("hello,world");String rep = dis.readUTF();System.out.println("主机返回的消息>: " + rep);dos.close();dis.close();}}服务端可以接收发来的消息，但是返回就不行，求解答！ 问题补充：苹果超人 写道
解决方案
if(!"".equals(msg)&&msg.length()!=0){ DataOutputStream dos = new DataOutputStream(clientSocket.getOutputStream()); String rep = "我是返回给由"+hostName+"发来["+msg+"]的消息"; System.out.println(rep); dos.writeUTF(rep); [color=red]dos.flush(); [/color] dos.close(); } 这边要调用一下flush方法，刷新一下，让服务器端把数据发送出去。
解决方案二：
DataInputStream dis = new DataInputStream(sk.getInputStream()); dos.writeUTF("hello,world"); 后要加上一句dos.writeUTF("");应该就可以了
解决方案三：
while (true) { msg = dis.readUTF(); System.out.println(hostName + "发来的消息>: " + msg); if(null==dis.readLine()||"".equals(dis.readLine())){ break; } } 你用的是readline来结束客户端的输出，但是看你客户端好像没有写入换行符。
解决方案四：
你写完数据时，都要flush一下IO通道的，这样才不会堵塞，呵呵，结贴吧。
解决方案五：
看到楼上的回复，看了下客户端的代码，在writeUTF之后，要flush一下，刷新下IO通道。
解决方案六：
Server端线程应该无法退出的while (true) { msg = dis.readUTF(); System.out.println(hostName + "发来的消息>: " + msg); if(null==dis.readLine()||"".equals(dis.readLine())){ break; } } 这段代码的意思是当读到内容后，打印出来，但是仅当读到的内容为空的时候才退出线程，否则一直阻塞在msg=dis.readUTF这儿。要想退出线程的话，可以和客户端约定一个特殊字符串，如bye，当客户端想要断开连接的时候，发送bye到服务端，而后服务端退出线程即可。当然不能忘了释放资源。