視頻聊天室源碼程序

1. 我想做仿映客的手機直播系統，最好能夠帶源碼，能否推薦一下啊

可以參考下紅雲直播的技術，據說有二十幾項專利，編解碼技術挺牛b的，能做到高清不卡，延遲小於1s，但是源碼開不開放我還不知道，你得自己找了

2. 用java編寫多人聊天室程序，不需要太復雜求大神發給我，最好能運行，有源代碼。謝謝了

文件1：
package com.qq;

import java.io.InputStream;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.DataOutputStream;
import java.io.BufferedReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.IOException;
import java.util.Date;

public class Server {
public Server() {
try {
ServerSocket s = new ServerSocket(8888);
Socket ss = s.accept();
OutputStream out = ss.getOutputStream();
DataOutputStream dout = new DataOutputStream(out);
InputStream in = ss.getInputStream();
DataInputStream din = new DataInputStream(in);
System.out.print(din.readUTF() + "!");
dout.writeUTF("你已經連接到服務姿坦器" + "\t" + "你的地址：" + ss.getInetAddress()
+ "\t" + "你的鏈接埠：" + ss.getLocalPort() + "\n");
new ReadMessage(din).start();
new SendMessage(dout).start();
} catch (IOException e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
new Server();
}
}

// 接受客戶含碼端信息
class ReadMessage extends Thread {
private DataInputStream din;

public ReadMessage(DataInputStream din) {
this.din = din;
}

public void run() {
String str;
try {
while (true) {
str = din.readUTF();
System.out.println(new Date().toLocaleString() + "客戶端說：" + str);
if (str.equals("bye")) {
System.out.println("客戶端下線！談冊哪");
break;
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

// 發出伺服器信息
class SendMessage extends Thread {
private DataOutputStream dout;

public SendMessage(DataOutputStream dout) {
this.dout = dout;
}

public void run() {
InputStreamReader inr = new InputStreamReader(System.in);
BufferedReader buf = new BufferedReader(inr);
String str;
try {
while (true) {
str = buf.readLine();
dout.writeUTF(str);
if (str.equals("bye")) {
System.out.println("伺服器退出！");
System.exit(1);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
----------------------------------------
文件2：
package com.qq;

import java.io.InputStream;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.DataOutputStream;
import java.io.BufferedReader;
import java.net.Socket;
import java.io.IOException;
import java.util.Date;

public class Client {
public Client() {
try {
Socket s = new Socket("192.168.1.2", 8888);
InputStream in = s.getInputStream();
DataInputStream din = new DataInputStream(in);
OutputStream out = s.getOutputStream();
DataOutputStream dout = new DataOutputStream(out);
dout.writeUTF("伺服器你好！我是客戶端");
System.out.println(din.readUTF());
new Thread(new SenderMessage(dout)).start();
new Thread(new ReaderMessage(din)).start();
} catch (IOException e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
new Client();
}
}

class ReaderMessage implements Runnable {
private DataInputStream din;

public ReaderMessage(DataInputStream din) {
this.din = din;
}

public void run() {
String str;
try {
while (true) {
str = din.readUTF();
System.out.println(new Date().toLocaleString() + "伺服器說：" + str);
if (str.equals("bye")) {
System.out.println("伺服器已經關閉，此程序自動退出！");
break;
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

class SenderMessage implements Runnable {
private DataOutputStream dout;

public SenderMessage(DataOutputStream dout) {
this.dout = dout;
}

public void run() {
String str;
InputStreamReader inf = new InputStreamReader(System.in);
BufferedReader buf = new BufferedReader(inf);
try {
while (true) {
str = buf.readLine();
dout.writeUTF(str);
if (str.equals("bye")) {
System.out.println("客戶端自己退出！");
System.exit(1);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}