[官方Demo]SocketDemo 通讯例子

[官方Demo]SocketDemo 通信例子

SocketDemo.java

?

/** * SocketDemo.java *  * Copyright ?1998-2010 Research In Motion Ltd. *  * Note: For the sake of simplicity, this sample application may not leverage * resource bundles and resource strings.  However, it is STRONGLY recommended * that application developers make use of the localization features available * within the BlackBerry development platform to ensure a seamless application * experience across a variety of languages and geographies.  For more information * on localizing your application, please refer to the BlackBerry Java Development * Environment Development Guide associated with this release. */package com.rim.samples.device.socketdemo;import net.rim.device.api.ui.*;/** * This sample enables client/server communication using a simple implementation  * of TCP sockets. The client application allows the user to select direct TCP as * the connection method.  If direct TCP is not selected, a proxy TCP connection * is opened using the BlackBerry MDS Connection Service. The server application  * can be found in com/rim/samples/server/socketdemo.  */public class SocketDemo extends UiApplication{       SocketDemoScreen _screen;        /**     * Entry point for application.     * @param Command line arguments.     */    public static void main(String[] args)    {        // Create a new instance of the application and make the currently        // running thread the application's event dispatch thread.        SocketDemo app = new SocketDemo();        app.enterEventDispatcher();    }        // Constructor    public SocketDemo()    {        // Create a new screen for the application.        _screen = new SocketDemoScreen();                // Push the screen onto the UI stack for rendering.        pushScreen(_screen);    }            /**     * Provides access to this application's UI screen     * @return This application's UI screen.     */    SocketDemoScreen getScreen()    {        return _screen;    }      }

?

SocketDemoScreen.java

?

/* * SocketDemoScreen.java * * Copyright ?1998-2010 Research In Motion Ltd. *  * Note: For the sake of simplicity, this sample application may not leverage * resource bundles and resource strings.  However, it is STRONGLY recommended * that application developers make use of the localization features available * within the BlackBerry development platform to ensure a seamless application * experience across a variety of languages and geographies.  For more information * on localizing your application, please refer to the BlackBerry Java Development * Environment Development Guide associated with this release. */package com.rim.samples.device.socketdemo;import net.rim.device.api.system.*;import net.rim.device.api.ui.*;import net.rim.device.api.ui.component.*;import net.rim.device.api.ui.container.*;/** * A MainScreen class to allow for user interaction. */public class SocketDemoScreen extends MainScreen{         private EditField _hostField;        private CheckboxField _useDirectTcpField;    private RichTextField _statusField;                  private StringBuffer _message;    private boolean _threadRunning = false;            // Constructor    public SocketDemoScreen()    {                  setTitle(new LabelField("Socket Demo"));                           add(new RichTextField("Enter local host name in the field below and select 'Go' from the menu." ,Field.NON_FOCUSABLE));        add(new SeparatorField());                // Need to get the local host name from the user because access to        // 'localhost' and 127.0.0.1 is restricted.        _hostField = new EditField("Local Host: " , "");            add(_hostField);                _useDirectTcpField = new CheckboxField("Use Direct TCP" , RadioInfo.getNetworkType() == RadioInfo.NETWORK_IDEN);        add(_useDirectTcpField);                _statusField = new RichTextField(Field.NON_FOCUSABLE);            add(_statusField);                _message = new StringBuffer();    }        /**    * Method to display a message to the user.    * @param msg The message to display.    */    void updateDisplay(final String msg)    {        UiApplication.getUiApplication().invokeLater(new Runnable()         {            public void run()            {                _message.append(msg);                _message.append('\n');                _statusField.setText(_message.toString());            }        });    }        /**     * Returns the text entered by the user.     * @return text entered by the user.     */    String getHostFieldText()    {        return _hostField.getText();    }        /**     * Indicates whether the direct TCP checkbox is checked.     * @return True if checkbox is checked, otherwise false.     */    boolean isDirectTCP()    {        return _useDirectTcpField.getChecked();    }        /**     * Setter for boolean _threadRunning     * @param running True if a ConnectThread is running, otherwise false.     */    void setThreadRunning(boolean running)    {        _threadRunning = running;    }       /**    *@see net.rim.device.api.ui.container.MainScreen#makeMenu(Menu,int)    */         protected void makeMenu(Menu menu, int instance)    {        // If a ConnectThread is running we won't add our menu item        if (!_threadRunning)        {            menu.add(_go);        }               super.makeMenu(menu, instance);    }       /**    * Prevent the save dialog from being displayed, nothing to save.    *     * @see net.rim.device.api.ui.container.MainScreen#onSavePrompt()    */    public boolean onSavePrompt()    {        return true;    }          /**    * Handles the user pressing ENTER while the     * 'use direct tcp' CheckboxField has focus.     *     * @see net.rim.device.api.ui.Screen#keyChar(char,int,int)    *     */    protected boolean keyChar( char key, int status, int time )    {        if ( key == Characters.ENTER )        {            Field fieldWithFocus = getFieldWithFocus();                         if(fieldWithFocus == _useDirectTcpField)            {                    if(_useDirectTcpField.getChecked())                    {                            _useDirectTcpField.setChecked(false);                    }                    else                    {                            _useDirectTcpField.setChecked(true);                    }                                                         return true; // We've consumed the event.                            }                    }                return super.keyChar( key, status, time ); // We'll let super handle the event.    }         /**    * An anonymous MenuItem class.    */         private MenuItem _go = new MenuItem("Go" , 11000, 0)    {        public void run()        {            // Don't do anything unless there is a host name in the _host field.            if (_hostField.getText().length() > 0)            {                new ConnectThread().start();                _threadRunning = true;                                 // Hide the virtual keyboard so the user can see status updates.                if(VirtualKeyboard.isSupported())                {                    VirtualKeyboard keyboard = getVirtualKeyboard();                    if(keyboard.getVisibility() != VirtualKeyboard.HIDE)                    {                        keyboard.setVisibility(VirtualKeyboard.HIDE);                    }                }                                                                     }            else            {                Dialog.ask(Dialog.D_OK, "Please enter a valid host name" );            }        }    };    }              

ConnectThread.java

/* * ConnectThread.java * * Copyright ?1998-2010 Research In Motion Ltd. *  * Note: For the sake of simplicity, this sample application may not leverage * resource bundles and resource strings.  However, it is STRONGLY recommended * that application developers make use of the localization features available * within the BlackBerry development platform to ensure a seamless application * experience across a variety of languages and geographies.  For more information * on localizing your application, please refer to the BlackBerry Java Development * Environment Development Guide associated with this release. */package com.rim.samples.device.socketdemo;import java.io.*;import javax.microedition.io.*;import net.rim.device.api.ui.*;/** * A thread class to handle communication with the server component. */public class ConnectThread extends Thread{           private InputStreamReader _in;    private OutputStreamWriter _out;            private SocketDemoScreen _screen;           // Constructor    public ConnectThread()    {        _screen = ((SocketDemo)UiApplication.getUiApplication()).getScreen();     }       /**    * Pass some data to the server and wait for a response.    * @param data The data to send.    */    private void exchange(String data) throws IOException    {        // Cache the length locally for better efficiency.        int length = data.length();                // Create an input array just big enough to hold the data        // (we're expecting the same string back that we send).        char[] input = new char[length];        _out.write(data, 0, length);        // Read character by character into the input array.        for (int i = 0; i < length; ++i)         {            input[i] = (char)_in.read();        }        // Hand the data to the parent class for updating the GUI. By explicitly         // creating the stringbuffer we can save a few object creations.        StringBuffer s = new StringBuffer();        s.append("Received: ") ;        s.append(input, 0, length);        _screen.updateDisplay(s.toString());    }   /**    * Implementation of Thread.    */    public void run()    {                StreamConnection connection = null;                       try        {            _screen.updateDisplay("Opening Connection...");            String url = "socket://" + _screen.getHostFieldText() + ":44444" + (_screen.isDirectTCP() ? ";deviceside=true" : "");                                                connection = (StreamConnection)Connector.open(url);            _screen.updateDisplay("Connection open");            _in = new InputStreamReader(connection.openInputStream());            _out = new OutputStreamWriter(connection.openOutputStream());                        // Send the HELLO string.            exchange("Hello");            // Execute further data exchange here...            // Send the GOODBYE string.            exchange("Goodbye and farewell");                                   _screen.updateDisplay("Done!");        }        catch(IOException e)        {            System.err.println(e.toString());        }        finally        {                          _screen.setThreadRunning(false);                        try            {                               _in.close();                         }            catch(IOException ioe)            {                            }            try            {                       _out.close();                         }            catch(IOException ioe)            {                           }            try            {                               connection.close();            }            catch(IOException ioe)            {                            }        }    }}

?

?