SocketSocket编程

 开发流程:
       服务器监听某个端口
       客户端连接服务器的某个端口
       通过SocketConnection通信

服务器监听某个端口:

  javax.microedition.io.Connector专门负责建立各种连接open(“socket://:端口”),返回  ServerSocketConnection ServerSocketConnection可以获得服务器IP和端口 如果有客户连上来,可以用ServerSocketConnection. acceptAndOpen()返回SocketConnection

客户端连接服务器端:

  javax.microedition.io.Connector专门负责建立各种连接
  open(“socket://IP地址:端口”),返回SocketConnection

服务器端

import java.io.DataInputStream;
import java.io.DataOutputStream;

import javax.microedition.io.Connector;
import javax.microedition.io.ServerSocketConnection;
import javax.microedition.io.SocketConnection;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;

public class ServerMIDlet2 extends MIDlet {

	protected void startApp() throws MIDletStateChangeException {
		try {
			ServerSocketConnection ssc = (ServerSocketConnection) Connector
					.open("socket://:9999");//监听9999端口
			SocketConnection sc = (SocketConnection) ssc.acceptAndOpen(); //等待客户端连接,如果有客户端连上，返回SocketConnection充当通信桥梁
			/*以后就可以通过sc与客户端通信*/
			System.out.println("客户端：" + sc.getAddress());
			/*接受客户端送来的字符串*/
			DataInputStream dis = sc.openDataInputStream();
			String msg = dis.readUTF();
			System.out.println(msg);

			DataOutputStream dos = sc.openDataOutputStream();
			dos.writeUTF("欢迎您连接服务器");

		} catch (Exception ex) {
			ex.printStackTrace();
		}

	}

	protected void destroyApp(boolean arg0) throws MIDletStateChangeException {
	}

	protected void pauseApp() {
	}

}

 

客户端

import java.io.DataInputStream;
import java.io.DataOutputStream;

import javax.microedition.io.Connector;
import javax.microedition.io.SocketConnection;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;

public class ClientMIDlet2 extends MIDlet {

	protected void startApp() throws MIDletStateChangeException {
		try {
			SocketConnection sc = (SocketConnection) Connector
					.open("socket://127.0.0.1:9999");// 连接到服务器端，连接成功，返回SocketConnection充当通信桥梁
			/* 以后就可以通过sc与服务器端通信 */
			DataOutputStream dos = sc.openDataOutputStream();
			// 送出去一个“你好”
			dos.writeUTF("你好");

			DataInputStream dis = sc.openDataInputStream();
			String msg = dis.readUTF();
			System.out.println(msg);

		} catch (Exception ex) {
			ex.printStackTrace();
		}

	}

	protected void destroyApp(boolean arg0) throws MIDletStateChangeException {
	}

	protected void pauseApp() {
	}

}