java 使用TCP实现单聊的功能。(客户端和服务端聊天)
2017-08-18 21:17
1021 查看
需求:
使用TCP实现单聊的功能。(客户端和服务端聊天)
代码:
package com.hcq.main2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import com.hcq.main2.Server.receiverMsg;
import com.hcq.main2.Server.sendMsg;
public class Client {
/**
* 使用TCP实现单聊的功能。(客户端和服务端聊天)
*
* @param args
*/
public static void main(String[] args) {
try {
System.out.println("创建客户端,并连接服务端...");
InetAddress byName = InetAddress.getByName("10.3.155.220");
Socket socket = new Socket(byName, 9408);
sendMsg sm = new sendMsg(socket);
receiverMsg rm = new receiverMsg(socket);
Thread t1 = new Thread(sm);
Thread t2 = new Thread(rm);
t1.start();
t2.start();
// socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
// 客户端发送信息给服务器
static class sendMsg implements Runnable {
private Socket socket;
private PrintWriter pw;
public sendMsg(Socket socket) {
super();
this.socket = socket;
}
@Override
public void run() {
try {
pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
while (true) {
pw.println(InputUtils.inputStr("客户端说: "));
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
// 客户端接收服务器信息
static class receiverMsg implements Runnable {
private Socket socket;
private String name;
public receiverMsg(Socket socket) {
super();
this.socket = socket;
this.name = socket.getInetAddress().getHostName();
}
@Override
public void run() {
try {
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
while (true) {
String readLine = br.readLine();
if (readLine == null) {
break;
}
System.out.println(name + " 说: " + readLine);
}
} catch (IOException
4000
e) {
e.printStackTrace();
}
}
}
}
截图:
![](https://img-blog.csdn.net/20170818211547661?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvYmVueGlhb2hhaTg4OA==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
使用TCP实现单聊的功能。(客户端和服务端聊天)
代码:
package com.hcq.main2;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import com.hcq.main2.Server.receiverMsg;
import com.hcq.main2.Server.sendMsg;
public class Client {
/**
* 使用TCP实现单聊的功能。(客户端和服务端聊天)
*
* @param args
*/
public static void main(String[] args) {
try {
System.out.println("创建客户端,并连接服务端...");
InetAddress byName = InetAddress.getByName("10.3.155.220");
Socket socket = new Socket(byName, 9408);
sendMsg sm = new sendMsg(socket);
receiverMsg rm = new receiverMsg(socket);
Thread t1 = new Thread(sm);
Thread t2 = new Thread(rm);
t1.start();
t2.start();
// socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
// 客户端发送信息给服务器
static class sendMsg implements Runnable {
private Socket socket;
private PrintWriter pw;
public sendMsg(Socket socket) {
super();
this.socket = socket;
}
@Override
public void run() {
try {
pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
while (true) {
pw.println(InputUtils.inputStr("客户端说: "));
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
// 客户端接收服务器信息
static class receiverMsg implements Runnable {
private Socket socket;
private String name;
public receiverMsg(Socket socket) {
super();
this.socket = socket;
this.name = socket.getInetAddress().getHostName();
}
@Override
public void run() {
try {
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
while (true) {
String readLine = br.readLine();
if (readLine == null) {
break;
}
System.out.println(name + " 说: " + readLine);
}
} catch (IOException
4000
e) {
e.printStackTrace();
}
}
}
}
package com.hcq.main2; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { try { System.out.println("创建服务端..."); ServerSocket serverSocket = new ServerSocket(9808); System.out.println("等待客户端连接..."); // 连接成功,返回一个Socket:对客户端的描述 Socket socket = serverSocket.accept(); System.out.println("客户端已连接..."); sendMsg sendMsg = new sendMsg(socket); receiverMsg receiverMsg = new receiverMsg(socket); Thread t1 = new Thread(sendMsg); Thread t2 = new Thread(receiverMsg); t1.start(); t2.start(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } // 服务器发送信息给客户端 static class sendMsg implements Runnable { private Socket socket; private PrintWriter pw; public sendMsg(Socket socket) { super(); this.socket = socket; } @Override public void run() { try { OutputStream os = socket.getOutputStream(); pw = new PrintWriter(new OutputStreamWriter(os), true); while (true) { pw.println(InputUtils.inputStr("服务器请说: ")); } } catch (IOException e) { e.printStackTrace(); } } } // 服务器接收客户端信息 static class receiverMsg implements Runnable { private Socket socket; private String name; public receiverMsg(Socket socket) { super(); this.socket = socket; this.name = socket.getInetAddress().getHostName(); } @Override public void run() { try { InputStream is = socket.getInputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(is)); while (true) { String readLine = br.readLine(); if (readLine == null) { break; } System.out.println(name + " 说: " + readLine); } } catch (IOException e) { e.printStackTrace(); } } } }
package com.hcq.main2; import java.util.Scanner; public class InputUtils { // 接收输入字符串方法 public static String inputStr(String tip) { System.out.println(tip); Scanner sc = new Scanner(System.in); return sc.next(); } }
截图:
相关文章推荐
- java在线聊天项目1.1版 ——开启多个客户端,分别实现注册和登录功能,使用客户端与服务端信息request机制,重构线程,将单独的登录和注册线程合并
- java在线聊天项目0.8版 实现把服务端接收到的信息返回给每一个客户端窗口中显示功能
- java在线聊天项目0.3版本 制作客户端窗体,实现发送按钮和回车发送信息功能,使用ActionListener监听事件中actionPerformed方法(用内部类和匿名内部类两种方法)
- java在线聊天项目0.4版本 制作服务端接收连接,客户端连接功能 新增客户端窗口打开时光标指向下边文本域功能,使用WindowListener监听WindowAdapter
- java TCP/IP实现简单的多人聊天功能
- 基于Socket的TCP长连接(服务端Java+客户端Android),Service配合AIDL实现
- Java基础---Java---网络编程---TCP的传输、客户端和服务端的互访、建立一个文本转换器、编写一个聊天程序
- Java写的TCP聊天程序,服务端收不到客户端发送的数据
- MingQQ v1.0高仿版开源了,使用WebQQ协议实现了QQ客户端基本的聊天功能...
- java在线聊天项目1.2版 ——开启多个客户端,分别实现数据库注册和登录功能后,成功登陆则登录框消失,好友列表窗出现
- 利用TCP和多线程实现服务端和多个客户端建立实时聊天小案例
- Java中使用socket实现客户端与服务端交互
- 使用Java实现B/S系统常见的获取客户端信息功能!
- java服务端对多个客户端的群聊功能代码实现
- java用ServerSocket类结合io流实现一对一聊天(java实现简单的TCP聊天程序只能用telnet连接后方可使用)
- 使用服务端和客户端两种方法 模拟网易邮箱实现全选,全不选的功能
- java实现客户端与服务端互传信息聊天(带界面)
- 1模拟网易邮箱实现全选,全不的功能(服务端和客户端) 2 使用DataList实现 加入购物车,编辑,删除,更新,取消功能。要求连一个产品表。
- Java简单实现TCP服务端和客户端通信
- java多线程<二>TCP/IP实现简单的多客户端聊天