[Java] Socket/ServerSocket/Thread 控制台聊天程序--两人任意聊
2011-04-20 13:27
615 查看
//服务器端代码
import java.io.*;
import java.net.*;
public class ServerTest3{
public static void main(String[] args){
try{
//设置sever端的链接
ServerSocket s = new ServerSocket(8888);
Socket s1 = s.accept();//sever等待链接
//实例化输出流
OutputStream os = s1.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//实例化输入流
InputStream is = s1.getInputStream();
DataInputStream dis = new DataInputStream(is);
//实例化两个线程的对象
Thread msr = new MyServerReader(dis);
Thread msw = new MyServerWriter(dos);
//启动线程
msr.start();
msw.start();
}
//捕获异常
catch(SocketException e){
System.out.println(e);
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来进行接收读取数据
class MyServerReader extends Thread{
private DataInputStream dis;
public MyServerReader (DataInputStream dis){
this.dis = dis;
}
public void run(){
String msg;
try{
while(true){
msg = dis.readUTF();
System.out.println("对方说:" + msg);
if(msg.equals("bye")){
System.out.println("对方下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来写入并发送数据
class MyServerWriter extends Thread{
private DataOutputStream dos;
public MyServerWriter(DataOutputStream dos){
this.dos = dos;
}
public void run(){
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
String msg;
try{
while(true){
msg = br.readLine();
dos.writeUTF(msg);
if(msg.equals("bye")){
System.out.println("自己下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//客户端代码
import java.io.*;
import java.net.*;
public class ClientTest3{
public static void main(String[] args){
try{
//链接sever端
Socket s1 = new Socket("127.0.0.1",8888);
//实例化输入流
InputStream is = s1.getInputStream();
DataInputStream dis = new DataInputStream(is);
//实例化输出流
OutputStream os = s1.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//实例化两个进程
Thread mcr = new MyClientReader(dis);
Thread mcw = new MyClientWriter(dos);
//启动两个进程
mcr.start();
mcw.start();
//捕获异常
}catch(SocketException e){
System.out.println(e);
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来进行接收读取数据
class MyClientReader extends Thread{
private DataInputStream dis;
public MyClientReader(DataInputStream dis){
this.dis = dis;
}
@Override
public void run(){
String msg;
try{
while(true){
msg = dis.readUTF();
System.out.println("对方说:"+msg);
if(msg.equals("bye")){
System.out.println("对方下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来写入并发送数据
class MyClientWriter extends Thread{
private DataOutputStream dos;
public MyClientWriter(DataOutputStream dos){
this.dos = dos;
}
@Override
public void run(){
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
String msg;
try{
while(true){
msg = br.readLine();
dos.writeUTF(msg);
if(msg.equals("bye")){
System.out.println("自己下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
打开两个控制台,先运行服务器端代码,再运行客户端代码,然后两端可以进行自由的通话
import java.io.*;
import java.net.*;
public class ServerTest3{
public static void main(String[] args){
try{
//设置sever端的链接
ServerSocket s = new ServerSocket(8888);
Socket s1 = s.accept();//sever等待链接
//实例化输出流
OutputStream os = s1.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//实例化输入流
InputStream is = s1.getInputStream();
DataInputStream dis = new DataInputStream(is);
//实例化两个线程的对象
Thread msr = new MyServerReader(dis);
Thread msw = new MyServerWriter(dos);
//启动线程
msr.start();
msw.start();
}
//捕获异常
catch(SocketException e){
System.out.println(e);
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来进行接收读取数据
class MyServerReader extends Thread{
private DataInputStream dis;
public MyServerReader (DataInputStream dis){
this.dis = dis;
}
public void run(){
String msg;
try{
while(true){
msg = dis.readUTF();
System.out.println("对方说:" + msg);
if(msg.equals("bye")){
System.out.println("对方下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来写入并发送数据
class MyServerWriter extends Thread{
private DataOutputStream dos;
public MyServerWriter(DataOutputStream dos){
this.dos = dos;
}
public void run(){
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
String msg;
try{
while(true){
msg = br.readLine();
dos.writeUTF(msg);
if(msg.equals("bye")){
System.out.println("自己下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//客户端代码
import java.io.*;
import java.net.*;
public class ClientTest3{
public static void main(String[] args){
try{
//链接sever端
Socket s1 = new Socket("127.0.0.1",8888);
//实例化输入流
InputStream is = s1.getInputStream();
DataInputStream dis = new DataInputStream(is);
//实例化输出流
OutputStream os = s1.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//实例化两个进程
Thread mcr = new MyClientReader(dis);
Thread mcw = new MyClientWriter(dos);
//启动两个进程
mcr.start();
mcw.start();
//捕获异常
}catch(SocketException e){
System.out.println(e);
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来进行接收读取数据
class MyClientReader extends Thread{
private DataInputStream dis;
public MyClientReader(DataInputStream dis){
this.dis = dis;
}
@Override
public void run(){
String msg;
try{
while(true){
msg = dis.readUTF();
System.out.println("对方说:"+msg);
if(msg.equals("bye")){
System.out.println("对方下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
//创建一个进程用来写入并发送数据
class MyClientWriter extends Thread{
private DataOutputStream dos;
public MyClientWriter(DataOutputStream dos){
this.dos = dos;
}
@Override
public void run(){
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
String msg;
try{
while(true){
msg = br.readLine();
dos.writeUTF(msg);
if(msg.equals("bye")){
System.out.println("自己下线,程序退出");
System.exit(0);
}
}
}catch(IOException e){
System.out.println(e);
}
}
}
打开两个控制台,先运行服务器端代码,再运行客户端代码,然后两端可以进行自由的通话
相关文章推荐
- [Java] Socket/ServerSocket/Thread 控制台聊天程序--两人任意聊
- [Java] Socket/ServerSocket 控制台简单聊天程序
- [Java] Socket/ServerSocket 控制台简单聊天程序
- java socket/serversocket/thread 服务器客户端任意聊天
- Java 基于多客户端的ServerSocket—聊天服务器端,客户端Socket “操作文件”系统的程序拼接
- java-用java.net.Socket和java.net.ServerSocket实现简单的聊天程序
- java用socket和serversocket实现一对一聊天(java实现简单的TCP聊天程序)
- Java 基于socket thread 简单聊天程序
- 基于Linux的Socket编程之TCP全双工Server-Client聊天程序
- java TCPSocket聊天小程序
- QT类似 4000 于QQ的即时聊天程序用开发QTcpServer,QTcpSocket简单开发
- Socket聊天程序(Server)
- 黑马程序员_Java基础_网络编程_UDP传输协议编程,控制台聊天程序
- 基于Socket的java网络编程(实现类似于QQ两人聊天的交互)
- Java socket模拟聊天程序
- JavaAWT简单Socket多人聊天程序(简单明了)
- 基于Linux的SOCKET编程之TCP半双工Client-Server聊天程序
- 详解基于java的Socket聊天程序――客户端(附demo)
- java聊天程序 基于socket 包含MySQL
- 聊天程序(基于Socket、Thread)