1.客户端
package tk.javazhangwei.net.tcp.chat.Demo03;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
/***
* 创建客户端 发送数据+接收数据
*
* @author zw
*
*/
public class Client {
public static void main(String[] args) throws IOException {
BufferedReader bf = new BufferedReader(new InputStreamReader(System.in));
System.out.println("请输入一个喜欢的名称：");
String name = bf.readLine();
if(name.equals("")) {
return;
}
Socket client = new Socket("localhost",1025);
//控制台输入信息
//控制台输入信息
new Thread(new Send(client,name)).start();//一条路径
new Thread(new Receive(client)).start();//一条路径
}
}2.服务端（写了个内部类：负责接收与发送多进程）
package tk.javazhangwei.net.tcp.chat.Demo03;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class Server {
List<myChannel> all = new ArrayList<myChannel>();
public static void main(String[] args) throws IOException {
new Server().start();
}
public void start() throws IOException {
ServerSocket server = new ServerSocket(1025);
while (true) {
Socket socket = server.accept();
myChannel mc = new myChannel(socket);
Thread t = new Thread(mc);
all.add(mc);
t.start();
}
}
/***
* 一个客户端 一个通路
* @author zw
*
*/
class myChannel implements Runnable{
private DataInputStream dis;
private DataOutputStream dos;
private boolean isRuning=true;
private String name;
public myChannel(Socket socket) throws IOException{
try {
dis = new DataInputStream(socket.getInputStream());
dos = new DataOutputStream(socket.getOutputStream());
this.name = dis.readUTF();
send("欢迎进入聊天室");
senOthers(this.name + "进入了聊天室");
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
isRuning=false;
dos.close();
dis.close();
}
}
/***
* 读取数据
*
* @return
* @throws IOException
*/
private String receive() throws IOException {
String msg ="";
try {
msg =dis.readUTF();
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
isRuning=false;
dis.close();
}
return msg;
}
/***
* 发送数据
* @throws IOException
*/
private void send(String msg) throws IOException {
if(msg==null&& msg.equals("")) {
return;
}
try {
dos.writeUTF(msg);
dos.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
isRuning=false;
dos.close();
all.remove(this);
}
}
/***
* 发送给其他客户端
* @throws IOException
*/
private void senOthers(String msg) throws IOException {
if (msg.startsWith("@")&&msg.indexOf(":")>-1) {// 表示为私聊
//获取name
String name = msg.substring(1, msg.indexOf(":"));
String content = msg.substring(msg.indexOf(":")+1);//获取冒号后的正文
for (myChannel others : all) {
if(others.name.equals(name)) {
others.send(this.name+"对您瞧瞧的说："+content);
}
}
} else {
//遍历容器
for(myChannel others:all) {
if(others == this) {//如果是本身，就跳过
continue;
}
others.send(this.name+"对所有人说："+msg);
}
}
}
@Override
public void run() {
while(isRuning) {
try {
senOthers(receive()) ;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}3.客户端的发送与接收多进程
package tk.javazhangwei.net.tcp.chat.Demo03;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
/***
* 发送数据
*
* @author zw
*
*/
public class Send implements Runnable{
//控制台输入流
private BufferedReader console;
//管道输出流
private DataOutputStream dos;
private String name;
private boolean isRuning =true;//线程是否运行
public Send() {
console =new BufferedReader(new InputStreamReader(System.in));
}
public Send(Socket client,String name) throws IOException {
this();
try {
dos = new DataOutputStream(client.getOutputStream());
this.name = name;
send(name);
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
isRuning =false;
dos.close();
console.close();
}
}
private String getMsgFromConsole() {
try {
return console.readLine();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return "";
}
@Override
public void run() {
while(isRuning) {
try {
send(getMsgFromConsole());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public void send(String msg) throws IOException {
if (msg!=null && !msg.equals("")) {
try {
dos.writeUTF(msg);
dos.flush();// 强制刷新
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
isRuning = false;
dos.close();
console.close();
}
}
}
}package tk.javazhangwei.net.tcp.chat.Demo03;
import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
/***
* 接收数据
* @author zw
*
*/
public class Receive implements Runnable{
//客户端的输入流
private DataInputStream dis;
private boolean isRuning = true;
public Receive() {
}
public Receive(Socket client) {
super();
try {
dis = new DataInputStream(client.getInputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
isRuning =false;
try {
dis.close();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
/***
* 接收数据
* @return
* @throws IOException
*/
public String receive() throws IOException {
String msg = "";
try {
msg =dis.readUTF();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
isRuning =false;
dis.close();
}
return msg;
}
@Override
public void run() {
while(isRuning) {
try {
System.out.println(receive());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}4.效果
