📄 client.java
字号:
import java.io.DataInputStream;
import java.io.InputStream;
import javax.microedition.io.Connector;
import javax.microedition.io.HttpConnection;
public class Client implements Runnable {
private Game midlet;
// private Queue qout;
HttpConnection dc;
private String port = "port=-1";
public Client(Game mid) {
// qout = new Queue();
midlet = mid;
sendMessage("register");
System.out.println("Success register!");
new Thread(this).start();
}
String urlReceive;
String urlSend;
public void run() {
while (true) {
StringBuffer strbuf = new StringBuffer();
urlReceive = "http://pc02:8080/XiangQiServer/XiangQi?message=hello&"
+ port;
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
try {
dc = (HttpConnection) Connector.open(urlReceive, Connector.READ);
InputStream is = null;
is = dc.openInputStream();
int len = (int) dc.getLength();
DataInputStream dis = new DataInputStream(is);
if (len > 0) {
byte[] data = new byte[len];
dis.readFully(data);
for (int i = 0; i < data.length; i++) {
strbuf.append((char) data[i]);
}
} else {
int ch;
len = 0;
while ((ch = dis.read()) != -1) {
strbuf.append((char) ch);
len++;
}
}
dis.close();
is.close();
dc.close();
String s = strbuf.toString().trim();
if (s != null && !s.equals("")) {
if(!s.equals("noData"))
System.out.println("message is is is:"+s);
if (s.startsWith("desks")) {
midlet.setDesks(s);
} else if (s.startsWith("takeseat")) {
midlet.takeSeat();
} else if (s.startsWith("updatedesk")) {
midlet.updateDesk(s);
} else if (s.startsWith("noData")) {
// System.out.println("noData... :"+port);
} else if (s.startsWith("port")) {
if (port.equals("port=-1"))
{
System.out.println("post");
port = s;
}
} else if (s.startsWith("<html>")) {
System.out
.println("send error return <html> is 500 or 404 error");
} else {
if (midlet.getCanvas() != null)
midlet.getCanvas().receiveMessage(s);
else
System.out.println("Error Canvas is null:::" + s);
}
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
public void sendMessage(String message) {
System.out.println("send message:" + message);
try { // Convert the string message to bytes
urlSend = "http://pc02:8080/XiangQiServer/XiangQi?message="
+ message + "&" + port;
HttpConnection dc = (HttpConnection) Connector.open(urlSend,
Connector.READ);
InputStream is = null;
is = dc.openInputStream();
is.close();
dc.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -