随便聊: 客户端: import java.net.*; import java.io.*;public class Client { public static void main(String[] args) throws Exception{ Socket s = new Socket("127.0.0.1",6689);
OutputStream os = s.getOutputStream(); InputStream is = s.getInputStream(); new ShuRu(is).start(); new ShuChu(os).start(); } } 服务器端: import java.net.*; import java.io.*; import java.util.*;public class Server { public static void main(String[] args) throws Exception{ ServerSocket ss = new ServerSocket(6689); Vector v = new Vector(); while(true){ Socket s = ss.accept(); InputStream is = s.getInputStream(); v.add(s); new SRThread(is,v).start(); } } }class SRThread extends Thread { Vector v; InputStream is;
import java.net.*;
import java.io.*;public class Client {
public static void main(String[] args) throws Exception{
Socket s = new Socket("127.0.0.1",6689);
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
new ShuRu(is).start();
new ShuChu(os).start();
}
} 服务器端:
import java.net.*;
import java.io.*;
import java.util.*;public class Server {
public static void main(String[] args) throws Exception{
ServerSocket ss = new ServerSocket(6689);
Vector v = new Vector();
while(true){
Socket s = ss.accept();
InputStream is = s.getInputStream();
v.add(s);
new SRThread(is,v).start();
}
}
}class SRThread extends Thread {
Vector v;
InputStream is;
public SRThread(InputStream is,Vector v){
this.is = is;
this.v = v;
}
public void run(){
BufferedReader br = new BufferedReader(new InputStreamReader(is));
try{
String str = br.readLine();
for(int i=0;i<v.size();i++){
Socket s = (Socket)v.get(i);
OutputStream os = s.getOutputStream();
PrintWriter pw = new PrintWriter(os,true);
pw.println(str);
}
}catch(IOException e){
e.printStackTrace();
}
}
} 接受和发送的类:
import java.net.*;
import java.io.*;public class ShuRu extends Thread{
InputStream is;
public ShuRu(InputStream is) {
this.is = is;
}
public void run(){
BufferedReader br = new BufferedReader(new InputStreamReader(is));
while(true){
try{
String str = br.readLine();
System.out.println (str);
if(str.equals("Bye")){
break;
}
}catch(IOException e){
e.printStackTrace();
}
}
}
}class ShuChu extends Thread {
OutputStream os;
public ShuChu(OutputStream os){
this.os = os;
}
public void run(){
PrintWriter pw = new PrintWriter(os,true);
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
while(true){
try{
String str = br.readLine();
pw.println(str);
if(str.equals("Bye")){
break;
}
}catch(IOException e){
e.printStackTrace();
}
}
}
}
import java.net.*;
import java.io.*;public class Client {
public Client() {
}
public static void main(String[] args) throws Exception {
Socket s = new Socket("localhost",9000);
InputStream is = s.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
OutputStream os = s.getOutputStream();
PrintWriter pw = new PrintWriter(os,true); BufferedReader brin = new BufferedReader(new InputStreamReader(System.in));
while(true){
String str = br.readLine();
System.out.println (str);
if(str.equals("Bye")){
s.close();
break;
}
String strin = brin.readLine();
pw.println(strin);
}
}
} 服务器端:
import java.net.*;
import java.io.*;public class Server {
public Server() {
}
public static void main(String[] args) throws Exception{
ServerSocket ss = new ServerSocket(9000);
Socket s = ss.accept();
OutputStream os = s.getOutputStream();
PrintWriter pw = new PrintWriter(os,true);
BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); InputStream is = s.getInputStream();
BufferedReader brp = new BufferedReader(new InputStreamReader(is));
while(true){
String str = br.readLine();
pw.println(str);
if(str.equals("Bye")){
s.close();
break;
}
String strb = brp.readLine();
System.out.println(strb);
}
}
}