Socket 用法

什么是Socket ?

网络上的两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。

简介 :

Socket的英文原义是“孔”或“插座”。作为BSD UNIX的进程通信机制,取后一种意思。通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄,可以用来实现不同虚拟机或不同计算机之间的通信。在Internet上的主机一般运行了多个服务软件,同时提供几种服务。每种服务都打开一个Socket,并绑定到一个端口上,不同的端口对应于不同的服务。Socket正如其英文原意那样,像一个多孔插座。一台主机犹如布满各种插座的房间,每个插座有一个编号,有的插座提供220伏交流电, 有的提供110伏交流电,有的则提供有线电视节目。 客户软件将插头插到不同编号的插座,就可以得到不同的服务。

架构 :

socket.jpg
流程.jpg

我们先来写服务端,其实服务端就是一个Socket通信,java文件

  • ChartService.java

public class ChartService {

    //用来存储多个客户端发来的请求
    List<Socket> client = new ArrayList<Socket>();
    
    //开始 的启动方法
    public void startServer(){
        try {
            ServerSocket ss = new ServerSocket(12345);
            //我们写一个循环来让它一直处于监听的状态 
            while(true){
                Socket socket = ss.accept();
                client.add(socket);
                this.new newThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    //我们写一个线程来执行来存储客户端发来的聊天数据
    class newThread extends Thread{
        Socket s ;
        BufferedReader bReader;
        public newThread(Socket s) {
            super();
            this.s = s;
            //用于接收数据 
            try {
                bReader = new BufferedReader(new InputStreamReader(s.getInputStream(),"utf-8"));
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            super.run();
            String data=null;
            try {
                while((data=bReader.readLine())!=null){
                    //遍历集合client
                    for(Socket s : client){
                        //輸出發送的數據
                        s.getOutputStream().write((data+"\n").getBytes());
                    }
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    //main方法,用於啟動java程序
    public static void main(String[] args) {
        new ChartService().startServer();
    }
}

客户端,我们就要把数据传到服务端,再从服务端获取传过去的数据,显示在文本框中,,

  • main.xml

    <EditText
        android:id="@+id/tv"
        android:layout_width="fill_parent"
        android:layout_height="300dp"
        android:enabled="false"
         />

    <EditText
        android:id="@+id/et_name"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:hint="昵称" />

    <EditText
        android:id="@+id/et_chart"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:hint="请输入聊天" />

    <Button
        android:id="@+id/send"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="发送" />
  • MainActivity.java

public class MainActivity extends Activity implements OnClickListener {

    private EditText et_name, et_chart;
    private EditText show;
    private Button send;
    Socket socket;
    Handler handler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            if (msg.what == 0x12) {
                String chat = show.getText().toString();
                String chat1 = msg.getData().getString("chart");
                show.setText(chat + "\n\n" + chat1);
            }
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        iviview();

        try {
            //设置本机的ip地址  端口号为服务端的端口号
            socket = new Socket("172.20.58.145", 12345);
            //利用线程来启动
            new ChartTherad(socket, handler).start();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    //初始化控件
    private void iviview() {
        et_name = (EditText) findViewById(R.id.et_name);
        et_chart = (EditText) findViewById(R.id.et_chart);
        show = (EditText) findViewById(R.id.tv);
        send = (Button) findViewById(R.id.send);
        send.setOnClickListener(this);
    }

    @Override
    public void onClick(View v) {
        if (v == send) {
            String name = et_name.getText().toString();
            String chart = et_chart.getText().toString();
            String data = name + ":" + chart + "\n";
            // 判断一下socket的值
            if (socket != null) {
                // 我们就输出这个data
                try {
                    // 传给服务器输出流(也就是发送数据)
                    socket.getOutputStream().write(data.getBytes("utf-8"));
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    class ChartTherad extends Thread {
        Socket client;
        Handler handler;

        public ChartTherad(Socket client, Handler handler) {
            super();
            this.client = client;
            this.handler = handler;
        }

        @Override
        public void run() {
            super.run();
            //用于接收从服务端获取的数据
            BufferedReader br;
            try {
                // 接受传过来的输入流
                br = new BufferedReader(new InputStreamReader(
                        client.getInputStream(), "utf-8"));
                while (true) {
                    String content = br.readLine();
                    // 传给主线程 进行更新
                    Bundle bundle = new Bundle();
                    bundle.putString("chart", content);
                    Message msg = new Message();
                    msg.setData(bundle);
                    msg.what = 0x12;
                    handler.sendMessage(msg);
                }
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
  • 权限:

<uses-permission android:name="android.permission.INTERNET"/>

注:4.0后会阻塞主线程的进程,因此都要开线程执行,这里主线程没有开线程,所以可用4.0以下版本的模拟器运行,,

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,590评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 86,808评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,151评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,779评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,773评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,656评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,022评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,678评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,038评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,756评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,411评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,005评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,973评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,053评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,495评论 2 343

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,596评论 18 139
  • 名词延伸 通俗的说,域名就相当于一个家庭的门牌号码,别人通过这个号码可以很容易的找到你。如果把IP地址比作一间房子...
    杨大虾阅读 20,586评论 2 57
  • 人生难觅知己,有时候相处好几年的朋友会措不及防的在背后捅你一刀,直中要害。有时候,仅仅是旅途中萍水相逢的朋友,却...
    流光小姐阅读 247评论 0 2
  • #该笔记由笔者整理自得到app《宁向东的清华管理课》# 摘要: 所有的合作,本质上都是资源互补。资源没有了互补性,...
    柴野兽阅读 1,423评论 0 1
  • 1 生活中,我们常常会遇到一些让人摸不着头脑的问题: 问题1:该怎么证明我妈是我妈?/如何实现自证? 北京市民陈先...
    宁冬青阅读 325评论 0 0