java多线程与socket
Ⅰ java socket多线程的问题可以多个线程使用同一个socket吗
可以写个demo试一下啊，应该是可以的，socket接收到的消息只能被其中一个线程接收。线程1 和2 接受到的肯定不是同一个消息。会有先后之分。看你怎么控制。比如从接收的消息是ABCD，那么这相当于一个资源。线程1和2在这里拿消息，拿到之后，socket里面就少了，比如线程1拿到AB，线程2拿到CD
Ⅱ java一个Socket连接多线程是否能操作两个读取流
可以啊 ，不过需要新建两个实现Runnable 借口的类，重写run方法，一个实现读取，另一个实现输出的功能。再用两条线程分别操作这两个方法。
Ⅲ Java入门基础需要学习什么
Java入门基础学习有很多坑，稍不留神可能你就学偏了，最后发现Java好难根本就学不会，Java确实有很多琐碎的知识点，所以对于初学者学习Java入门基础需要理清楚学习流程。那么Java入门基础需要学习什么？
Java入门基础是新手的敲门砖，千里之行，始于足下，基础打好，以后学习就会一帆风顺了。那么Java入门基础需要学习什么呢？
1、Java简介
了解什么是Java；代码语法基本格式；输出表达式。
了解Java的大致编译以及执行过程。
2、Java语言基础、循环、数组；了解类和对象。
掌握Java的基本数据类型和引用数据类型有哪些。
掌握强制数据类型转换和自动类型提升规则。
常滚没裤量如何声明及赋值。
循环的语法及作用。
掌握类的概念及什么是对象。
3、OOP封装大简、继承、多态
面向对象的三大特征。(这块内容非常重要，相对来说较为难以理解)
4、java.util.*包下的常用类。
lang包下的基本数据类型对应的包装类(Byte,Short,Integer,Long,Double,Float,Character,Boolean)；
字符串相关的类String、StringBuffer、StringBuilder.
5、IO流操作，多线程以及Socket
掌握IO读写流相关的类，了解字节流，字符流和字符流缓冲区；
掌握线程的概念，多线程的创建、启动方式，锁和同步的概念及运用；
掌握Socket通信的概念，如何声明客户端服务端，如何完成双端通信；
掌握数据库的基本概念，Mysql的安装、启动与停止；
Mysql数据库客户端的安装与使用；
JDBC的概念，在Java中使用Mysql驱动包连接Mysql。
通过第一阶段的学习掌握Java语法和常用类，数据库入门技术相关知识。让自己对于存储，IO，这些有个大概的了解。
这时候，暂时不需要花大量的精力以及篇幅去学习多线程和Socket，当然这里不是说他们不重要，而是对于现阶段的你，或许很难非常清晰的明白以及了解他们具体的作用。
这里第一节忽察陆略掉了Swing，Swing章节的内容可以不学，因为在实际的工作中基本上没有用武之地。新手在第一阶段的学习是最难熬的，因为这个阶段需要记的东西特别多，但是又不像看小说一样，什么东西都能看明白，建议大家先过一遍基础内容，不明白的地方可以先放一边，回头可以慢慢捡。
此外，不建议开始学就抱一本书在那里慢慢啃，可以找一些讲的比较好的视频跟着学。
Java入门基础其实没有想象中的那么难，我们制定好Java学习路线图然后按照Java学习路线进行学习可能会事半功倍，如果你对于Java入门基础需要学习什么？还是比较迷茫建议填写下面的表单即可获得昌平北大青鸟Java培训班免费体验课程，让昌平北大青鸟讲师为你制定Java入门基础学习路线图。
Ⅳ socket java实现客户端多线程接受消息并发送消息给服务器，并发执行
客服端：
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class KeFuDuan {
public static void main(String[] args) {
KeFuDuan kf = new KeFuDuan();
kf.start();
}
public void start(){
Socket sco;
String ss= "";
try {
sco = new Socket("127.0.0.1",8866);
KeFuanJie kf = new KeFuanJie(sco);
KeFuWuFasong kfs = new KeFuWuFasong(sco);
kf.start();
kfs.start();
//sco.close();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class KeFuanJie extends Thread{
Socket soc;
String ss;
BufferedReader br;
public KeFuanJie(Socket soc){
try {
this.soc = soc;
br = new BufferedReader(new InputStreamReader(soc.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
//负责接受服务端来的信息
public void run(){
while(true){
//接受服务器端来的信息
try {
ss = br.readLine();
System.out.println("服务器---->客服端： "+ss);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
//向服务器发送东西
class KeFuWuFasong extends Thread{
Socket soc;
BufferedWriter bw;
BufferedReader brr;
public KeFuWuFasong(Socket soc){
this.soc = soc;
try {
brr =new BufferedReader(new InputStreamReader(System.in));
bw = new BufferedWriter(new OutputStreamWriter(soc.getOutputStream()));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run(){
while(true){
//向服务器发送请求
try {
bw.write(brr.readLine());
bw.newLine();
bw.flush();// 或者用bw.close()
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
服务器端：
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
Server server = new Server();
server.start();
}
public void start(){
try { //服务器端打开端口
ServerSocket server = new ServerSocket(4499);
Socket socket = null;
ServerToClientThread stct = null;
while(true){
socket = server.accept(); //迎接（接收）客户端的Socket访问
stct = new ServerToClientThread(socket); //分配一个新线程负责和信赖的Socket沟通
stct.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class ServerReceiveFromClient extends Thread{
Socket socket;
BufferedReader br;
String s;
public ServerReceiveFromClient(Socket socket){
this.socket = socket;
try {
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
while(true){
try {
s = br.readLine();
System.out.println(socket.getInetAddress().getHostAddress()+"发送了:"+s);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class ServerToClientThread extends Thread{
Socket socket;
BufferedReader br;
BufferedWriter bw;
String s;
//建立的同时，和客户端的Socket建立输入、输出流
public ServerToClientThread(Socket socket){
this.socket = socket;
try {
bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
ServerReceiveFromClient srfc = new ServerReceiveFromClient(socket);
srfc.start();
while(true){
try {
bw.write("欢迎光临。");
bw.newLine();
bw.flush();
Thread.sleep(10*1000);
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Ⅳ JAVA程序完成服务器和客户端的SOCKET通讯，要求服务器使用多线程接收和处理多个客户端访问请求
1. 客户端程序
import java.io.*;
import java.net.*;
public class TalkClient {
public static void main(String args[]) {
try{
Socket socket=new Socket("127.0.0.1",4700);
//向本机的4700端口发出客户请求
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系统标准输入设备构造BufferedReader对象
PrintWriter os=new PrintWriter(socket.getOutputStream());
//由Socket对象得到输出流，并构造PrintWriter对象
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket对象得到输入流，并构造相应的BufferedReader对象
String readline;
readline=sin.readLine(); //从系统标准输入读入一字符串
while(!readline.equals("bye")){
//若从标准输入读入的字符串为 "bye"则停止循环
os.println(readline);
//将从系统标准输入读入的字符串输出到Server
os.flush();
//刷新输出流，使Server马上收到该字符串
System.out.println("Client:"+readline);
//在系统标准输出上打印读入的字符串
System.out.println("Server:"+is.readLine());
//从Server读入一字符串，并打印到标准输出上
readline=sin.readLine(); //从系统标准输入读入一字符串
} //继续循环
os.close(); //关闭Socket输出流
is.close(); //关闭Socket输入流
socket.close(); //关闭Socket
}catch(Exception e) {
System.out.println("Error"+e); //出错，则打印出错信息
}
}
}
2. 服务器端程序
import java.io.*;
import java.net.*;
import java.applet.Applet;
public class TalkServer{
public static void main(String args[]) {
try{
ServerSocket server=null;
try{
server=new ServerSocket(4700);
//创建一个ServerSocket在端口4700监听客户请求
}catch(Exception e) {
System.out.println("can not listen to:"+e);
//出错，打印出错信息
}
Socket socket=null;
try{
socket=server.accept();
//使用accept()阻塞等待客户请求，有客户
//请求到来则产生一个Socket对象，并继续执行
}catch(Exception e) {
System.out.println("Error."+e);
//出错，打印出错信息
}
String line;
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket对象得到输入流，并构造相应的BufferedReader对象
PrintWriter os=newPrintWriter(socket.getOutputStream());
//由Socket对象得到输出流，并构造PrintWriter对象
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系统标准输入设备构造BufferedReader对象
System.out.println("Client:"+is.readLine());
//在标准输出上打印从客户端读入的字符串
line=sin.readLine();
//从标准输入读入一字符串
while(!line.equals("bye")){
//如果该字符串为 "bye"，则停止循环
os.println(line);
//向客户端输出该字符串
os.flush();
//刷新输出流，使Client马上收到该字符串
System.out.println("Server:"+line);
//在系统标准输出上打印读入的字符串
System.out.println("Client:"+is.readLine());
//从Client读入一字符串，并打印到标准输出上
line=sin.readLine();
//从系统标准输入读入一字符串
} //继续循环
os.close(); //关闭Socket输出流
is.close(); //关闭Socket输入流
socket.close(); //关闭Socket
server.close(); //关闭ServerSocket
}catch(Exception e){
System.out.println("Error:"+e);
//出错，打印出错信息
}
}}