|
導(dǎo)讀微信小程序,簡(jiǎn)稱小程序,英文名Mini Program,是一種不需要下載安裝即可使用的應(yīng)用,它實(shí)現(xiàn)了應(yīng)用“觸手可及”的夢(mèng)想,用戶掃一掃或搜一下即可打開應(yīng)用。小程序是一種不用下載就能使用的應(yīng)用,也是一... 微信小程序,簡(jiǎn)稱小程序,英文名Mini Program,是一種不需要下載安裝即可使用的應(yīng)用,它實(shí)現(xiàn)了應(yīng)用“觸手可及”的夢(mèng)想,用戶掃一掃或搜一下即可打開應(yīng)用。小程序是一種不用下載就能使用的應(yīng)用,也是一項(xiàng)門檻非常高的創(chuàng)新,經(jīng)過將近兩年的發(fā)展,已經(jīng)構(gòu)造了新的小程序開發(fā)環(huán)境和開發(fā)者生態(tài)。 一個(gè)很簡(jiǎn)單的網(wǎng)絡(luò)聊天小工具,java實(shí)現(xiàn),雙向同步發(fā)送信息,功能增加中局域網(wǎng)內(nèi)ip請(qǐng)自行更改,只要變更c(diǎn)lient端的localhost ip為另一臺(tái)pc的ip就行 import java.io.*;
import java.net.Socket;
import java.net.ServerSocket;
import java.net.SocketException;
public class TestServer {
public static void main(String[] args) {
try {
//open the communication port for messenge-transfer
//server socket id:8888
ServerSocket s = new ServerSocket(8888);
//create socket instance and set it be waiting state to accept data
Socket s1 = s.accept();
//original data stream
InputStream is = s1.getInputStream();
OutputStream os = s1.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
DataInputStream dis = new DataInputStream(is);
System.out.println("Server started!");
new MyServerReader(dis).start();
new MyServerWriter(dos).start();
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
}
class MyServerReader extends Thread {
private DataInputStream dis;
public MyServerReader(DataInputStream dis) {
this.dis = dis;
}
public void run() {
String info;
try {
while (true) {
info = dis.readUTF();
System.out.println("Ta said:" + info);
if (info.equals("bye") || info.equals("88")) {
System.out.println("Ta offline, connection's out!");
System.exit(0);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
class MyServerWriter extends Thread {
private DataOutputStream dos;
public MyServerWriter (DataOutputStream dos) {
this.dos = dos;
}
public void run() {
String info;
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
try {
while (true) {
info = br.readLine();
dos.writeUTF(info);
if (info.equals("bye") || info.equals("88")) {
System.out.println("Local machine Offline, application exit!");
System.exit(0);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}client端的: import java.io.*;
import java.net.Socket;
import java.net.SocketException;
public class TestClient {
public static void main (String[] args) {
try {
Socket s1 = new Socket("127.0.0.1", 8888);
InputStream is = s1.getInputStream();
OutputStream os = s1.getOutputStream();
DataInputStream dis = new DataInputStream(is);
DataOutputStream dos = new DataOutputStream(os);
new MyClientReader(dis).start();
new MyClientWriter(dos).start();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class MyClientReader extends Thread {
private DataInputStream dis;
public MyClientReader(DataInputStream dis) {
this.dis = dis;
}
public void run() {
String info;
try {
while (true) {
info = dis.readUTF();
System.out.println("Ta said:" + info);
if (info.equals("bye") || info.equals("88")) {
System.out.println("Ta offline, connection's out!");
System.exit(0);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
class MyClientWriter extends Thread {
private DataOutputStream dos;
public MyClientWriter (DataOutputStream dos) {
this.dos = dos;
}
public void run() {
String info;
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
try {
while (true) {
info = br.readLine();
dos.writeUTF(info);
if (info.equals("bye") || info.equals("88")) {
System.out.println("Local machine Offline, application exit!");
System.exit(0);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}以上就是雙向同步聊天小程序[ByJavaOnLinux]實(shí)現(xiàn)代碼的詳細(xì)內(nèi)容,更多請(qǐng)關(guān)注php中文網(wǎng)其它相關(guān)文章! 小程序是一種不需要下載安裝即可使用的應(yīng)用,它實(shí)現(xiàn)了應(yīng)用“觸手可及”的夢(mèng)想,用戶掃一掃或者搜一下即可打開應(yīng)用。 |
溫馨提示:喜歡本站的話,請(qǐng)收藏一下本站!