聊天，QQ，微信，陌陌很多的即时通讯的软件，不管是桌面端还是移动端，在当今社交的时代都是不可或缺的一部分。这时候说Socket和ServerSocket感觉有点老调重弹感觉，相信很多人早就知道如何使用了，而且利用这个通信原理可能已经开发出很多优秀的通信软件吧，但是我感觉这个对于刚接触java网络编程的人来说，学会Socket通信实现聊天软件，是必须的一步，了解其中的原理更是非常重要的一步，对，很多人可能觉得对着视频敲出一个软件很容易，但是你能学到什么？？？盲目地崇拜大神吗？？，我认为需要花更多的时间去弄懂其实现的原理，然后总结一些属于自己的东西出来。本人菜鸟，但是喜欢分享一些自己的东西，希望能帮助需要帮助的人，不说废话，直接上...
为了照顾一下初学者下面就大概说下Socket的介绍:
1、Scoket又称“套接字”，应用程序通常通过“套接字”向网络发出请求或者应答网络请求

在 java中Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端

Socket是建立网络连接时使用的，在连接成功时，应用程序两端都会产生一个Socket实例

操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别

不因为在服务器端或在客户端而产生不同的级别，不管是Socket还是ServerSocket他们的

工作都是通过Socket类和其子类来完成的

2、建立Socket链接可分三个步骤:

         1.服务器监听

         2.客户端发出请求

         3.建立链接

         4.通信

3、Socket特点:

          1.基于TCP链接，数据传输有保障

          2.适用于建立长时间的链接，不像HTTP那样会随机关闭

          3.Socket编程应用于即时通讯
4、ServerSocket的建立和使用:
public class ServerSocket_Test {
 public static void main(String[] args) {

  //port参数表示服务器监听的端口号，从1-65535

  try {

   

   ServerSocket serverSocket =new ServerSocket(12345);

      

   //block，当没有客户端连接时，改主线程会一直阻塞等待连接，一直监听，直到有客户端连接才会执行

  Socket socket= serverSocket.accept();//侦听事务的连接，accept是一个阻塞的方法，会阻塞当前的main线程，并且返回的是一个Socket类型

  //建立连接，表示serverSocket在监听，如果监听到有客户端连接则会调用accept方法，然后返回一个Socket，最后建立连接

  JOptionPane.showMessageDialog(null, "有客户端连接到了本机的12345端口");

  //然后测试在浏览器中输入http://127.0.0.1:12345则会弹出相应有客户端连接的提示框，然后原来阻塞在accept方法那里就会往下执行

  } catch (IOException e) {

   e.printStackTrace();

  }

 }

注意:但是以上的这种方法不推荐，因为这个里面有线程阻塞，会阻塞主线程，所以推荐一种更好的方法是就是单独开启一个线程去实现服务器监听客户端的连接
5、ServerSocketListener(单独的线程实现服务器的监听)
public class ServerListener extends Thread {

 @Override

 public void run() {

  //port参数表示服务器监听的端口号，从1-65535

  try {
   ServerSocket serverSocket =new ServerSocket(12345);
   while (true) {   //由于可能当有多个客户端连接时，accept方法就会产生多个Socket对象，需加一个while循环监听来自客户端的连接

    //block，当没有客户端连接时，改主线程会一直阻塞等待连接，一直监听，直到有客户端连接才会执行

    Socket socket= serverSocket.accept();//侦听事务的连接，accept是一个阻塞的方法，会阻塞当前的main线程，并且返回的是一个Socket类型

    //建立连接，表示serverSocket在监听，如果监听到有客户端连接则会调用accept方法，然后返回一个Socket，最后建立连接

    JOptionPane.showMessageDialog(null, "有客户端连接到了本机的12345端口");

    //然后测试在浏览器中输入http://127.0.0.1:12345则会弹出相应有客户端连接的提示框，然后原来阻塞在accept方法那里就会往下执行

   

    //将socket传递给另起的一个新的线程,即是socket通信的线程

    new ChatSocket(socket).start();

   

   }

   

  } catch (IOException e) {

   e.printStackTrace();

  }

 }
然后在主方法去开启这个线程即可:
public class ServerSocket_Test {
 public static void main(String[] args) {

  new ServerListener().start();

 }
}
用浏览器打开运行结果（表示此时已经有客户端连接到服务器了，监听到客户端后就会弹出提示框，此时的浏览器就相当于客户端）：

 
那么接下来就讲解一下聊天服务器端（ServerSocket）的是实现:
主要实现原理:因为一个客户端就相当于开启一个Socket线程，然而要实现多人聊天，就相当于开启多个Socket线程（即多个客户端），然后把这些线程加入到Vector集合中去，当客户端（Socket）发送一条信息时，也就相当于服务器（ServerSocket）读入信息，而对于客户端是向服务器输入，实现输入流Socket.InputStream,然后利用BufferReader缓冲流读入服务器，然后在服务器（ServerSocket）中的去遍历这个线程集合，如果不是当前客户端对象就发送信息，这样就是实现了把当前客户端信息转发给其他的客户端使用Socket.OutputStream,即服务器向客户端输出流，并用PrintWriter流写入客户端。
具体见图:
ServerSocket代码:
1、ServerSocket.java：
public class ServerSocket {
 public static void main(String[] args) {

  new ServerListener().start();

  //运行的方法在command命令下输入:"telnet localhost 12345",每建立一个就是一个客户端，而且每个客户端享受不同的线程，等级是平等的

 }
2.ServerListener.java
public class ServerListener extends Thread {

 @Override

 public void run() {

  //port参数表示服务器监听的端口号，从1-65535

  try {
   ServerSocket serverSocket =new ServerSocket(12345);

   while (true) {//由于可能当有多个客户端连接时，accept方法就会产生多个Socket对象，需加一个while循环监听来自客户端的连接

    Socket socket= serverSocket.accept();//侦听事务的连接，accept是一个阻塞的方法，会阻塞当前的main线程，并且返回的是一个Socket类型

    //建立连接，表示serverSocket在监听，如果监听到有客户端连接则会调用accept方法，然后返回一个Socket，最后建立连接

    JOptionPane.showMessageDialog(null, "有客户端连接到了本机的12345端口");

    

    ChatSocket cs= new ChatSocket(socket);

        cs.start();//开启ChatSocket线程

        ChatManager.getchaChatManager().add(cs);

   }

   

  } catch (IOException e) {

   e.printStackTrace();

  }

 }

}

3.ChatSocket.java
public class ChatSocket extends Thread {

//创建一个Socket对象来接收SocketListener传来的Socket对象

 Socket socket;

 public ChatSocket(Socket s) {

          this.socket=s;

}

 public void out(String out){

  try {

   socket.getOutputStream().write((out+"\n").getBytes("UTF-8"));//接收来自服务器端的数据

  }catch (UnsupportedEncodingException e) {

   e.printStackTrace();

  }

  catch (IOException e) {

   System.out.println("断开了一个客户端链接");

   ChatManager.getchaChatManager().remove(this);

   e.printStackTrace();

  }

 }

 @Override

  public void run() {

     out("您已经连接到服务器");

    try {

  

  BufferedReader br=new BufferedReader(

    new InputStreamReader(

      socket.getInputStream(),"UTF-8"));//当前服务器会不断读取当前客户端的数据

  String line=null;

     while ((line=br.readLine())!=null) {//客户端发送给服务器的数据

    //然后服务器再将所有的信息转发给每一个客户端，调用publish方法

      

      ChatManager.getchaChatManager().publish(this, line);

   }

     br.close();

     System.out.println("断开了一个客户端链接");

   ChatManager.getchaChatManager().remove(this);

 } catch (IOException e) {

  System.out.println("断开了一个客户端链接");

  ChatManager.getchaChatManager().remove(this);

  e.printStackTrace();

 }

     

 }
4、ChatManager.java
public class ChatManager {

      //因为一个聊天服务器只有一个ChatManager所以需要创建一个单例

 

 private ChatManager(){}

 private static final ChatManager cm= new ChatManager();

 public static  ChatManager getchaChatManager(){

  return cm;

 }

 

 Vector<ChatSocket> vector=new Vector<ChatSocket>();

 public void add(ChatSocket cs){

      vector.add(cs);//将每一个线程加入集合中

 }

 public void remove(ChatSocket cs) {

  vector.remove(cs);

 }

 public  void publish(ChatSocket cs,String chatinfo){//表示当前的线程给集合中的每一个线程发送的信息，也即当前的客户端给每一个客户端发送信息

  //要给集合中所有的线程发送信息就必须遍历这个集合

  for (int i = 0; i < vector.size(); i++) {

   ChatSocket csChatSocket=vector.get(i);

   if(!csChatSocket.equals(cs)){//则需要判断不许给当前客户端发送信息，也即不给自己发送信息

    csChatSocket.out(chatinfo);//发送信息给其他的客户端

   }

  }

 }

}
 
到现在其实我们就可以测试聊天和多人聊天的功能:
运行的方法:我们打开Command命令，输入telnet localhost 12345，然后回车，就会建立起一个多人聊天室：

运行结果:

那接下来讲解聊天客户端的实现:
客户端的实现主要是有两部分，第一是GUI的实现，这个在这就不多讲了这是GUI（Swing）界面编程的知识，第二个就是客户端的逻辑的实现，因为客户端既要发送信息
又要接收信息，发送信息给服务器则需要Socket.getInputStream字节流，转换成InputStreamReader字符流，转换成BufferReader缓冲流，read到服务器；接收信息，从服务器中接收信息，则需要Socket.OutputStream字节流，转换成OutputStream转换成PrintWriter流，write到客户端。
代码:
ChatManager：
public class ChatManager {

  private ChatManager(){}

  private static final ChatManager instance =new ChatManager();

  public static ChatManager getChatManager(){

   return instance;

  }

  MainWindow window;

  String IP;

  Socket socket;

  BufferedReader br;

  PrintWriter pw;

  public void setWindow(MainWindow window) {

 this.window = window;

 window.appendText("文本框已经和Manage绑定了");

}

  public void connect(String ip){

   this.IP=ip;

   new Thread(){
  @Override

  public void run() {

      try {

       socket=new Socket(IP, 12345);//创建客户端，连接的端口是ServerSocket的端口

       pw=new PrintWriter(

         new OutputStreamWriter(

           socket.getOutputStream(),"UTF-8") );

       br=new BufferedReader(

         new InputStreamReader(

           socket.getInputStream(),"UTF-8"));

       String line;

       

       while ((line=br.readLine())!=null) {

    window.appendText("收到:"+line);

   }

       br.close();

      pw.close();

      pw=null;

      br=null;

  
      }catch (UnknownHostException e) {

    e.printStackTrace();

   } 

      catch (IOException e) {

   e.printStackTrace();

  }

  }

   }.start();

  }

  public void send(String out){

   if(pw!=null){

    pw.write(out+"\n");

    pw.flush();

   }else{

  window.appendText("已中断与服务器的连接");  

   }

  }

}
StartClient.java：
public class StartClient {
 public static void main(String[] args) {

  EventQueue.invokeLater(new Runnable() {

   public void run() {

    try {

     MainWindow frame = new MainWindow();

     frame.setVisible(true);

     ChatManager.getChatManager().setWindow(frame);

    } catch (Exception e) {

     e.printStackTrace();

    }

   }

  });

 }
}
 
GUI界面代码:
package com.zhongqihong.client.view;
import java.awt.BorderLayout;

import java.awt.EventQueue;
import javax.swing.JFrame;

import javax.swing.JPanel;

import javax.swing.border.EmptyBorder;

import javax.swing.JTextArea;

import javax.swing.GroupLayout;

import javax.swing.GroupLayout.Alignment;

import javax.swing.JTextField;

import javax.swing.JButton;

import javax.swing.LayoutStyle.ComponentPlacement;
import com.zhongqihong.client.ChatManager;
import java.awt.event.MouseAdapter;

import java.awt.event.MouseEvent;
public class MainWindow extends JFrame {
 private static final long serialVersionUID = 1L;

 private JPanel contentPane;

 JTextArea txt;

 private JTextField ip;

 private JTextField send;

 /**

  * Create the frame.

  */

 public MainWindow() {

  setAlwaysOnTop(true);

  setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

  setBounds(100, 100, 450, 300);

  contentPane = new JPanel();

  contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));

  setContentPane(contentPane);

  

  txt = new JTextArea();

  txt.setText("Ready...");

  

  ip = new JTextField();

  ip.setText("127.0.0.1:808");

  ip.setColumns(10);

  

  JButton button = new JButton("\u8FDE\u63A5\u5230\u670D\u52A1\u5668");

  button.addMouseListener(new MouseAdapter() {

   @Override

   public void mouseClicked(MouseEvent e) {

    ChatManager.getChatManager().connect(ip.getText());

   }

  });

  

  send = new JTextField();

  send.setText("\u60A8\u597D");

  send.setColumns(10);

  

  JButton button_1 = new JButton("\u53D1\u9001");

  button_1.addMouseListener(new MouseAdapter() {

   @Override

   public void mouseClicked(MouseEvent e) {

    ChatManager.getChatManager().send(send.getText());

     appendText("我说:"+send.getText());

        send.setText("");

   }

  });

  GroupLayout gl_contentPane = new GroupLayout(contentPane);

  gl_contentPane.setHorizontalGroup(

   gl_contentPane.createParallelGroup(Alignment.LEADING)

    .addGroup(Alignment.TRAILING, gl_contentPane.createSequentialGroup()

     .addComponent(ip, GroupLayout.DEFAULT_SIZE, 277, Short.MAX_VALUE)

     .addGap(18)

     .addComponent(button, GroupLayout.PREFERRED_SIZE, 119, GroupLayout.PREFERRED_SIZE)

     .addContainerGap())

    .addGroup(Alignment.TRAILING, gl_contentPane.createSequentialGroup()

     .addComponent(send, GroupLayout.DEFAULT_SIZE, 251, Short.MAX_VALUE)

     .addGap(18)

     .addComponent(button_1, GroupLayout.PREFERRED_SIZE, 135, GroupLayout.PREFERRED_SIZE)

     .addGap(20))

    .addComponent(txt, GroupLayout.DEFAULT_SIZE, 424, Short.MAX_VALUE)

  );

  gl_contentPane.setVerticalGroup(

   gl_contentPane.createParallelGroup(Alignment.LEADING)

    .addGroup(gl_contentPane.createSequentialGroup()

     .addContainerGap()

     .addGroup(gl_contentPane.createParallelGroup(Alignment.BASELINE)

      .addComponent(ip, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE)

      .addComponent(button))

     .addPreferredGap(ComponentPlacement.RELATED)

     .addComponent(txt, GroupLayout.DEFAULT_SIZE, 174, Short.MAX_VALUE)

     .addPreferredGap(ComponentPlacement.RELATED)

     .addGroup(gl_contentPane.createParallelGroup(Alignment.BASELINE)

      .addComponent(send, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE)

      .addComponent(button_1))

     .addContainerGap())

  );

  contentPane.setLayout(gl_contentPane);

 }

public void appendText(String in){

 txt.append("\n"+in);

}

}
public class ServerSocket_Test {
 public static void main(String[] args) {

  new ServerListener().start();

  //运行的方法在command命令下输入:"telnet localhost 12345",每建立一个就是一个客户端，而且每个客户端享受不同的线程，等级是平等的

 }
}
 }

 }


运行代码:


两人私聊:

多人群聊:

到这里，我们的多人聊天的客户端就成功实现了，其实一步一步来，把复杂的问题分解成一个个小问题来解决就可以了。
PS：这里是Demo的源码:http://pan.baidu.com/s/1qWQikMC

 
 

酷传数据显示，网易上线一款社交软件“声波”。
声波开发商为网易(杭州)网络有限公司，于11月12日上线0.0.1版本，目前仅可在OPPO安卓应用商店下载。
经产品猎人(ID：qqchanpin)体验，声波是一款主打语音交友的陌生人社交软件。用户在完成登录后即可选择进入不同的语音房间进行互动社交。目前产品还处在初期，部分功能尚不稳定。
具体来讲，声波的核心功能为：
其一，加入或自建多人语聊房。声波首页“推荐”界面会为用户推荐6个语音房间，“声波大厅”会显示当前所有语音房间。由于产品初期房间数较少，尚未看出房间推荐逻辑。
每个语音房间均有一名房主和八个麦位。用户进入房间后可以自由申请上麦，也可以文字互动。
用户也可以自建语音房间，不过需要进行实名认证后方能创建。创建后可以在“我的房间”中查看。
其二，礼物打赏。用户在语音房间内可以向房主或其他用户赠送礼物。房间内设有根据每周用户送礼数据排名的“贡献榜”，和根据每周用户收礼数据排名的“魅力榜”。
打赏礼物需要使用“波币”购买，用户可在“我的钱包”内充值波币。因产品处测试阶段，目前所有数量波币充值金额均为0.01元。
同时根据用户消费情况，也会提升用户个人等级，不同等级区间拥有不同的等级图标。高等级用户除了拥有炫酷的等级图标外，在语音房观众列表中也能名列前茅。
其三，匿名社交。用户可以向其他用户发起私聊，关注其他用户后成为对方的粉丝。双方相互关注即可成为好友。用户可以在消息界面中查看好友、关注和粉丝。同时，用户可以邀请粉丝进入其所在的语音房间。
在各大巨头相继布局、社交领域竞争越发激烈的情况下，网易上线“声波”开始探索语音社交领域。当前市场上主打语音交友的陌生人社交产品数量较多，其中也不乏音遇、吱呀等热门产品。
YY也在今年推出产品“追吖”布局语音社交。“追吖”会根据用户兴趣领域引导用户选择相关的语音房间进行1对1配对语聊。“声波”虽然主打多人语聊，但在用户引导方面存在缺失。
多人语聊房延伸出的玩法非常多，例如多人聊天+游戏互动、多人聊天+赛事直播、多人聊天+pia戏等，垂直领域不同，每种玩法的产品都有所差别。
以目前的体验来看，“声波”采用的是多人纯语聊+观众的模式，在核心功能上并没有比较突出的创新和变化。同时，玩法又较为单一，缺乏垂直领域和用户引导。但鉴于目前产品尚处于测试阶段，还可以保持期待。

 

用了一段时间Clubhouse，给大家分享一下我对clubhouse的一些理解，本片文章一个多人的实时在线音频社交软件，邀请制模式，5G大流量时代，重新给出了语音社交的定义，其开放性的模式、简洁极致的用户体验，给用户带来非常不一样的感受。

 



     1.一个注册用户只能邀请两个新用户，而且还必须是iPhone用户；

     2.在短短的八个月时间内，Clubhouse的用户增长了8000倍，现在总人数超过了500万，估值已涨到了50亿美元；

     3.听众在clubhouse里面只能听主持人和嘉宾聊天，或者举手上麦发言，不支持文字聊天，不能发图片，没有弹幕功能，更不能打赏刷礼物，它只是一个单纯的社交产品，每个房间都是由开房间的用户自建主题，甚至很多房间都没有主题，它更像是一个广场，用户在房间里面就是聊天、分享、倾听，遇到感兴趣的人可以关           注，你关注的人一旦新建了一个房间，系统也会给你发通知，国内的语聊产品走的是另外一条路线，有专门的内容运营，唱歌的、说脱口秀的、PK的还有炒CP的可以说是更注重的是娱乐化，普通用户也特别强调存在感，恨不得一进来就发一个大火箭，告诉所有人我来了，在clubhouse里面分为发言人、关注发言人的人和倾      听者，三种类型的人，分为不同的权限。任意的人都可以举手发言，保证了room的发言的次序，从而让每一位听众都能非常好，如果你像发言你就举手发言，有主持人邀请你上台发言，如果你不想发言，可以躲在任意的角落倾听就好了。



    4.不过clubhouse和YY还是有一点联系的，他的音频技术服务商来自于中国声网公司，而声网的创始人就是前YY的CTO，所以clubhouse一火声网的股票大涨了30%。另外还意外的带动了国内的音频平台”荔枝“，一度大涨了90%。

    5.现在clubhouse也火爆国内外，全球IT圈最近都在讨论这个产品设计和商业模式，仅2月6号1天国内自媒体增加了近5W的报道量。

    6.如何体验clubhouse,它的邀请码在淘宝、拼多多等平台上标价499元，而且在随着用户的增长，即使花钱，很难买到邀请码，国外一个邀请码被炒到了1000美元。而且国内版还没上线，只有使用非大陆appleId才可以下载安装，不过这也不是难事，某宝上花个几块钱就能提供appleid供你下载。

	

点击上面“蓝字”关注我们！
语音直播系统开发找【卢经理：186微1316电8035同号】，语言交友社交直播系统开发，语音直播平台开发，语言交友APP开发，类似系统开发。
从字面意思来看，语音交友是“不看脸”不看颜值的一种社交的方式，通过声音的传递来表达人们的感情。由于现在“看脸”的社交软件有很多，人们在社交的时候都会去看对方的颜值，更加注重长相方面，从而忽略了很多方面，失去了初心的社交方式。为了能够帮助更多的人找到自己的灵魂伴侣，从而减轻现代社会带来的交友压力，所以我们研发了语音直播社交的开发。
根据中新网给出的数据显示，2020年3月，中国网民的数量已经突破了9亿达到9.04亿人。而2019年，移动视频领域的用户规模达到了惊人的7.74亿，这意味着85.6%的网民都已经成为了移动视频的目标用户。
坐拥庞大的用户群体，高喊视频为王的自然顺理成章。与此同时，与“屏幕经济”相得益彰的“耳朵经济”也正以后来者的姿态直追迎上。
不过整体上看，在线音频行业呈现出好的趋势。艾媒咨询发布的《2019上半年中国在线音频市场研究报告》显示，在线音频行业目前总体呈现三大向好态势：其一，在线音频市场有望保持稳定快速增长态势;其二，语音内容付费仍有较大的潜力。其三，在线音频平台泛娱乐生态渐成趋势。
语音直播和视频直播有一些相似的点，但是两者之间又有许多的不同，语音最核心的一点就是声音更适合某些内容的呈现。知识网红、垂直大V的内容更适合语音直播，像任务访谈，情感电台等形式的传播更适合语音。语音直播应用了互联网为主的新技术，实现了更强的互动，有了更多变现的可能。
虽然现在的直播系统大多都是视频类型的直播，但是语音直播系统源码也能给人们带来无限的可能和惊喜，语音可以应用于教育和科普类，传播性更强，可以快速的达到知识的变现，语音能够带来新的发展，当然语音的发展也不只这些。
语音直播源码的开发是在于视频直播系统的一种形式，当视频直播占领大多市场的时候，选择语音系统的源码也是一种非常明智的选择，快节奏的生活下，选择弯道超车也未必是一种错误的选择，也是一种快速超越的一种方式，语音直播应用了更多直播的技术直播方式，互动性更强，让一些不敢尝试做主播的人们选择一个更好的方式，不需要你的职业，不需要颜值的直播方式，可以大胆尝试，让语音直播源码不再单调。相信在不久的将来，语音直播源码也会应用到更加广泛的市场中。
更多热门系统
模式开发请扫码
联系我们